Include key in checkpointed data

s4 · Oct 19, 2011 · cf685ab · cf685ab
1 parent c22c2ee
commit cf685ab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s4-core/src/main/java/io/s4/processor/AbstractPE.java b/s4-core/src/main/java/io/s4/processor/AbstractPE.java
@@ -94,7 +94,7 @@ public String getName() {
     transient private List<EventAdvice> eventAdviceList = new ArrayList<EventAdvice>();
     transient private List<Object> keyValue;
     transient private List<Object> keyRecord;
-    transient private String keyValueString;
+    private String keyValueString;
     transient private String streamName;
     transient private boolean saveKeyRecord = false;
     transient private int outputsBeforePause = -1;