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 <[email protected]>
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
[email protected].
