You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/18 20:08:15 UTC
[15/50] [abbrv] beam git commit: Reduce Log Level of
PubsubUnboundedSource
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, "