beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [15/50] [abbrv] beam git commit: Reduce Log Level of PubsubUnboundedSource
Date Thu, 18 May 2017 20:08:15 GMT
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 <tgroh@google.com>
Authored: Mon May 15 10:00:45 2017 -0700
Committer: Thomas Groh <tgroh@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, "


Mime
View raw message