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 <[email protected]> Authored: Wed Sep 13 16:17:14 2017 +0800 Committer: basti.lj <[email protected]> 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()); } }
