Small fix for BigtableIO.WriteOperation.finalize

gsgalloway · web-flow · commit 4a9f16469fec · 2017-03-01T15:22:22.000-08:00
diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/bigtable/BigtableIO.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/bigtable/BigtableIO.java
@@ -976,9 +976,9 @@ public void initialize(PipelineOptions options) {}
     public void finalize(Iterable<Long> writerResults, PipelineOptions options) {
       long count = 0;
       for (Long value : writerResults) {
-        value += count;
+        count += value;
       }
-      logger.debug("Wrote {} elements to BigtableIO.Sink {}", sink);
+      logger.debug("Wrote {} elements to BigtableIO.Sink {}", count, sink);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -976,9 +976,9 @@ public void initialize(PipelineOptions options) {}`
`976`	`976`	`public void finalize(Iterable<Long> writerResults, PipelineOptions options) {`
`977`	`977`	`long count = 0;`
`978`	`978`	`for (Long value : writerResults) {`
`979`		`- value += count;`
	`979`	`+ count += value;`
`980`	`980`	`}`
`981`		`- logger.debug("Wrote {} elements to BigtableIO.Sink {}", sink);`
	`981`	`+ logger.debug("Wrote {} elements to BigtableIO.Sink {}", count, sink);`
`982`	`982`	`}`
`983`	`983`
`984`	`984`	`@Override`