Fix kryo exception
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11caa978 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11caa978 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/11caa978 Branch: refs/heads/master Commit: 11caa9789fa843991231cdba73fbd738cb6d8fe2 Parents: a7b5d98 Author: manuzhang <owenzhang1...@gmail.com> Authored: Mon Jun 19 19:12:45 2017 +0800 Committer: manuzhang <owenzhang1...@gmail.com> Committed: Mon Jun 19 21:29:53 2017 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java | 2 ++ .../beam/runners/gearpump/translators/functions/DoFnFunction.java | 1 - 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/11caa978/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java index ae59121..5febf3c 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java @@ -106,6 +106,8 @@ public class GearpumpRunner extends PipelineRunner<GearpumpPipelineResult> { serializers.put("org.apache.beam.sdk.values.KV", ""); serializers.put("org.apache.beam.sdk.transforms.windowing.IntervalWindow", ""); serializers.put("org.apache.beam.sdk.values.TimestampedValue", ""); + serializers.put( + "org.apache.beam.runners.gearpump.translators.utils.TranslatorUtils$RawUnionValue", ""); if (userSerializers != null && !userSerializers.isEmpty()) { serializers.putAll(userSerializers); http://git-wip-us.apache.org/repos/asf/beam/blob/11caa978/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/functions/DoFnFunction.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/functions/DoFnFunction.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/functions/DoFnFunction.java index b20896a..fde265a 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/functions/DoFnFunction.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/functions/DoFnFunction.java @@ -144,7 +144,6 @@ public class DoFnFunction<InputT, OutputT> extends Object emptyValue = WindowedValue.of( Lists.newArrayList(), value.getTimestamp(), sideInputWindow, value.getPane()); sideInputReader.addSideInputValue(sideInput, (WindowedValue<Iterable<?>>) emptyValue); - System.out.println(sideInput + " in " + sideInputWindow.toString() + " not ready"); } } }
