You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/08/07 23:53:58 UTC
[33/50] [abbrv] beam git commit: Fix kryo exception
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 <ow...@gmail.com>
Authored: Mon Jun 19 19:12:45 2017 +0800
Committer: manuzhang <ow...@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");
}
}
}