beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From p..@apache.org
Subject [1/2] beam git commit: JStorm-runner: Remove unnecessary WARN log, which might case confusion.
Date Thu, 14 Sep 2017 11:29:54 GMT
Repository: beam
Updated Branches:
  refs/heads/jstorm-runner ef70031b7 -> cd9c548b6


JStorm-runner: Remove unnecessary WARN log, which might case confusion.


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/03cc311c
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/03cc311c
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/03cc311c

Branch: refs/heads/jstorm-runner
Commit: 03cc311cfbabd92390d7a848a135b59d9d80530c
Parents: ef70031
Author: basti.lj <basti.lj@alibaba-inc.com>
Authored: Wed Sep 13 16:17:14 2017 +0800
Committer: basti.lj <basti.lj@alibaba-inc.com>
Committed: Wed Sep 13 16:17:58 2017 +0800

----------------------------------------------------------------------
 .../beam/runners/jstorm/translation/TranslatorRegistry.java    | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/03cc311c/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/translation/TranslatorRegistry.java
----------------------------------------------------------------------
diff --git a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/translation/TranslatorRegistry.java
b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/translation/TranslatorRegistry.java
index c8ea545..f297dc3 100644
--- a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/translation/TranslatorRegistry.java
+++ b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/translation/TranslatorRegistry.java
@@ -48,10 +48,6 @@ class TranslatorRegistry {
   }
 
   public static TransformTranslator<?> getTranslator(PTransform<?, ?> transform)
{
-    TransformTranslator<?> translator = TRANSLATORS.get(transform.getClass());
-    if (translator == null) {
-      LOG.warn("Unsupported operator={}", transform.getClass().getName());
-    }
-    return translator;
+    return TRANSLATORS.get(transform.getClass());
   }
 }


Mime
View raw message