incubator-s4-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mmo...@apache.org
Subject [1/50] [abbrv] git commit: matthieu's checkpointing test fix: adding AbstractPE.keyValueString as part of reference PE, because keyValueString was set as checkpointable in a recent commit
Date Tue, 03 Jan 2012 11:19:14 GMT
Updated Branches:
  refs/heads/dev [created] 45efb827d


matthieu's checkpointing test fix: adding AbstractPE.keyValueString as part of reference PE,
because keyValueString was set as checkpointable in a recent commit


Project: http://git-wip-us.apache.org/repos/asf/incubator-s4/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-s4/commit/45efb827
Tree: http://git-wip-us.apache.org/repos/asf/incubator-s4/tree/45efb827
Diff: http://git-wip-us.apache.org/repos/asf/incubator-s4/diff/45efb827

Branch: refs/heads/dev
Commit: 45efb827d6a33d41e8db89bf4ecc842feda5d406
Parents: bca594c
Author: Bruce Robbins <robbins@everychoose-lm.corp.yahoo.com>
Authored: Mon Nov 28 20:33:27 2011 -0800
Committer: Bruce Robbins <robbins@everychoose-lm.corp.yahoo.com>
Committed: Mon Nov 28 20:33:27 2011 -0800

----------------------------------------------------------------------
 .../java/org/apache/s4/ft/CheckpointingTest.java   |    7 +++++++
 1 files changed, 7 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/45efb827/s4-core/src/test/java/org/apache/s4/ft/CheckpointingTest.java
----------------------------------------------------------------------
diff --git a/s4-core/src/test/java/org/apache/s4/ft/CheckpointingTest.java b/s4-core/src/test/java/org/apache/s4/ft/CheckpointingTest.java
index c0dfa30..37f2a9a 100644
--- a/s4-core/src/test/java/org/apache/s4/ft/CheckpointingTest.java
+++ b/s4-core/src/test/java/org/apache/s4/ft/CheckpointingTest.java
@@ -1,5 +1,6 @@
 package org.apache.s4.ft;
 
+import org.apache.s4.processor.AbstractPE;
 import org.apache.s4.serialize.KryoSerDeser;
 
 import java.io.File;
@@ -93,6 +94,12 @@ public class CheckpointingTest extends S4TestCase {
 
             StatefulTestPE refPE = new StatefulTestPE();
             refPE.setValue1("message1");
+            
+            // NOTE since commit cf685ab080870764d5aee4037587ebe918ce890b keyValueString
is also checkpointed, 
+            // therefore we must set it so that it is included in checkpointed data
+            Field keyValueStringField = AbstractPE.class.getDeclaredField("keyValueString");
   
+            keyValueStringField.setAccessible(true);    
+            keyValueStringField.set(refPE, "value");
             refPE.setId("statefulPE");
             refPE.setKeys(new String[] {});
             KryoSerDeser kryoSerDeser = new KryoSerDeser();


Mime
View raw message