commit cd9c548b6e1ee57f3a202da64e5e55bc6704b67f
author Pei He <pei@apache.org> Thu Sep 14 19:29:31 2017 +0800
committer Pei He <pei@apache.org> Thu Sep 14 19:29:31 2017 +0800
tree 54b659cf7c9637b038c985bff9c2162b8795dc95
parent ef70031b7b0e48ae5750725f8ff6a9cd71f37431
parent 03cc311cfbabd92390d7a848a135b59d9d80530c

This closes #3846

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 @@
   }
 
   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());
   }
 }