[11/53] [abbrv] refactored to simplify vastly improved test of activity serialization fixed jackson mapper configuration issues causing better tests to fail

[sb...@apache.org]

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b59bcd28/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsProcessorExec.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsProcessorExec.java b/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsProcessorExec.java
index 437011c..4203787 100644
--- a/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsProcessorExec.java
+++ b/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsProcessorExec.java
@@ -21,7 +21,7 @@ import java.util.concurrent.TimeUnit;
 /**
  * Created by sblackmon on 3/25/14.
  */
-@MonitoredUDF(timeUnit = TimeUnit.SECONDS, duration = 10, intDefault = 10)
+@MonitoredUDF(timeUnit = TimeUnit.SECONDS, duration = 30, intDefault = 10)
 public class StreamsProcessorExec extends EvalFunc<DataBag> {
 
     TupleFactory mTupleFactory = TupleFactory.getInstance();

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b59bcd28/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsSerializerExec.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsSerializerExec.java b/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsSerializerExec.java
index 1f0e619..a217f83 100644
--- a/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsSerializerExec.java
+++ b/streams-runtimes/streams-runtime-pig/src/main/java/org/apache/streams/pig/StreamsSerializerExec.java
@@ -32,35 +32,26 @@ public class StreamsSerializerExec extends EvalFunc<String> {
 
     public StreamsSerializerExec(String... execArgs) throws ClassNotFoundException{
         Preconditions.checkNotNull(execArgs);
-        System.out.println("A");
         Preconditions.checkArgument(execArgs.length > 0);
-        System.out.println("B");
         String classFullName = execArgs[0];
         Preconditions.checkNotNull(classFullName);
-        System.out.println("C");
         String[] constructorArgs = new String[execArgs.length-1];
         ArrayUtils.remove(execArgs, 0);
         ArrayUtils.addAll(constructorArgs, execArgs);
-        System.out.println("D");
         activitySerializer = StreamsComponentFactory.getSerializerInstance(Class.forName(classFullName));
-        System.out.println("E");
     }
 
     @Override
     public String exec(Tuple input) throws IOException {
 
         Preconditions.checkNotNull(activitySerializer);
-        System.out.println("1");
         Preconditions.checkNotNull(input);
-        System.out.println("2");
         Preconditions.checkArgument(input.size() == 1);
-        System.out.println("3");
         Configuration conf = UDFContext.getUDFContext().getJobConf();
 
         String document = (String) input.get(0);
 
         Preconditions.checkNotNull(document);
-        System.out.println("4");
         Activity activity = null;
         try {
             activity = activitySerializer.deserialize(document);