beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject incubator-beam git commit: Fix condition in FlinkStreamingPipelineTranslator
Date Wed, 31 Aug 2016 11:44:00 GMT
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 <aljoscha.krettek@gmail.com>
Authored: Wed Aug 31 13:42:30 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
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.");


Mime
View raw message