Remove print to stdout
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cb8c5e5e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cb8c5e5e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cb8c5e5e Branch: refs/heads/gearpump-runner Commit: cb8c5e5e59348897e0bc04d5ffb885c15a18c6af Parents: c37de00 Author: manuzhang <owenzhang1...@gmail.com> Authored: Fri Dec 16 16:50:08 2016 +0800 Committer: manuzhang <owenzhang1...@gmail.com> Committed: Fri Dec 16 16:50:08 2016 +0800 ---------------------------------------------------------------------- .../runners/gearpump/translators/FlattenPCollectionTranslator.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/cb8c5e5e/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/FlattenPCollectionTranslator.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/FlattenPCollectionTranslator.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/FlattenPCollectionTranslator.java index b06d5a8..b740ab5 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/FlattenPCollectionTranslator.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/FlattenPCollectionTranslator.java @@ -33,7 +33,6 @@ public class FlattenPCollectionTranslator<T> implements @Override public void translate(Flatten.FlattenPCollectionList<T> transform, TranslationContext context) { JavaStream<T> merged = null; - System.out.println("PCollectionList size " + context.getInput(transform).size()); for (PCollection<T> collection : context.getInput(transform).getAll()) { JavaStream<T> inputStream = context.getInputStream(collection); if (null == merged) {
