Reduce Log Level of PubsubUnboundedSource
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8060d660 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8060d660 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8060d660 Branch: refs/heads/gearpump-runner Commit: 8060d66083973cdab91f68085652ab68e3dee596 Parents: d4df907 Author: Thomas Groh <tg...@google.com> Authored: Mon May 15 10:00:45 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Mon May 15 10:00:45 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/8060d660/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java index e8fe701..b7df804 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java @@ -863,7 +863,7 @@ public class PubsubUnboundedSource extends PTransform<PBegin, PCollection<Pubsub (nowMsSinceEpoch - inFlight.get(oldestAckId).requestTimeMsSinceEpoch) + "ms"; } - LOG.info("Pubsub {} has " + LOG.debug("Pubsub {} has " + "{} received messages, " + "{} current unread messages, " + "{} current unread bytes, "
