Merge pull request #555 from gsgalloway/patch-1

Small fix for BigtableIO's WriteOperation.finalize
GoogleCloudPlatform · Mar 2, 2017 · c4bff0b · c4bff0b
2 parents fc5fee2 + 4a9f164
commit c4bff0b
Showing 1 changed file with 2 additions and 2 deletions.
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