Repository: incubator-beam Updated Branches: refs/heads/master 1dc1f25b6 -> 98da6e8fb
Fix condition in FlinkStreamingPipelineTranslator Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/98da6e8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/98da6e8f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/98da6e8f Branch: refs/heads/master Commit: 98da6e8fb014d2a93b7441f6b2b131968d874ab6 Parents: 1dc1f25 Author: Aljoscha Krettek <[email protected]> Authored: Wed Aug 31 13:42:30 2016 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Aug 31 13:42:30 2016 +0200 ---------------------------------------------------------------------- .../flink/translation/FlinkStreamingPipelineTranslator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/98da6e8f/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingPipelineTranslator.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingPipelineTranslator.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingPipelineTranslator.java index b127455..284cd23 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingPipelineTranslator.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingPipelineTranslator.java @@ -84,7 +84,7 @@ public class FlinkStreamingPipelineTranslator extends FlinkPipelineTranslator { StreamTransformTranslator<?> translator = FlinkStreamingTransformTranslators.getTranslator(transform); - if (translator == null && applyCanTranslate(transform, node, translator)) { + if (translator == null || !applyCanTranslate(transform, node, translator)) { LOG.info(node.getTransform().getClass().toString()); throw new UnsupportedOperationException( "The transform " + transform + " is currently not supported.");
