You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2016/06/01 10:08:13 UTC
[1/2] incubator-beam git commit: [BEAM-295] Remove erroneous close()
calls in Flink Create Sources
Repository: incubator-beam
Updated Branches:
refs/heads/master a829d9caf -> e9c0d8d05
[BEAM-295] Remove erroneous close() calls in Flink Create Sources
Collector.close() should only be called by internal Flink components,
not by user functions.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/971ea4de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/971ea4de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/971ea4de
Branch: refs/heads/master
Commit: 971ea4de225f6efdd9ff862a6ff74ed05299f8a4
Parents: a829d9c
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed May 18 17:46:34 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Jun 1 12:06:43 2016 +0200
----------------------------------------------------------------------
.../wrappers/streaming/io/FlinkStreamingCreateFunction.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/971ea4de/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
index 8cd8351..0d72f65 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
@@ -52,7 +52,5 @@ public class FlinkStreamingCreateFunction<IN, OUT> implements FlatMapFunction<IN
out.collect(WindowedValue.of(outValue, Instant.now(), GlobalWindow.INSTANCE, PaneInfo.NO_FIRING));
}
-
- out.close();
}
}
[2/2] incubator-beam git commit: This closes #347
Posted by al...@apache.org.
This closes #347
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9c0d8d0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9c0d8d0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e9c0d8d0
Branch: refs/heads/master
Commit: e9c0d8d056a7ecfba447ea9bfeda4366ff44dcff
Parents: a829d9c 971ea4d
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Jun 1 12:07:07 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Jun 1 12:07:07 2016 +0200
----------------------------------------------------------------------
.../wrappers/streaming/io/FlinkStreamingCreateFunction.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------