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);
