This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new e1b6fb7 Change info to debug statement new afa7e86 Change info to debug statement e1b6fb7 is described below commit e1b6fb7f7cd3a8bdbfa1de0e9b091ef8ff155a35 Author: keithmcneill <mcne...@anibla.net> AuthorDate: Wed Jan 31 20:57:31 2018 -0500 Change info to debug statement This log line creates a huge amount of noise in the logs. In addition with google charging for stackdriver I believe that this will cost a lot of $$'s --- .../src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java | 2 +- .../test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java index 1de30de..63138bb 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java @@ -716,7 +716,7 @@ public class BigtableIO { public void finishBundle() throws Exception { bigtableWriter.flush(); checkForFailures(); - LOG.info("Wrote {} records", recordsWritten); + LOG.debug("Wrote {} records", recordsWritten); } @Teardown diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java index efe6292..e1fab40 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java @@ -825,7 +825,7 @@ public class BigtableIOTest { .apply("write", defaultWrite.withTableId(table)); p.run(); - logged.verifyInfo("Wrote 1 records"); + logged.verifyDebug("Wrote 1 records"); assertEquals(1, service.tables.size()); assertNotNull(service.getTable(table)); -- To stop receiving notification emails like this one, please contact lc...@apache.org.