From 4a9f16469fec467cf54efaa98a658413da231a00 Mon Sep 17 00:00:00 2001
From: gsgalloway <gsgalloway@users.noreply.github.com>
Date: Wed, 1 Mar 2017 15:22:22 -0800
Subject: [PATCH] Small fix for BigtableIO.WriteOperation.finalize

---
 .../com/google/cloud/dataflow/sdk/io/bigtable/BigtableIO.java | 4 ++--
 1 file changed, 2 insertions(+), 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
index 3751d160f5..62f3b25d57 100644
--- 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