bugfix

Author: rwiggles

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java

@@ -723,8 +723,8 @@ private void validateCommitRequestSize() {
     // so, we're purposefully dropping them here
     Windmill.WorkItemCommitRequest.Builder truncationBuilder =
         buildWorkItemTruncationRequestBuilder(currentWork, estimatedCommitSize);
-    this.outputBuilder.clear();
-    this.outputBuilder.mergeFrom(truncationBuilder);
+    currentBuilder.clear();
+    currentBuilder.mergeFrom(truncationBuilder.build());
   }
 
   private Windmill.WorkItemCommitRequest.Builder buildWorkItemTruncationRequestBuilder(

runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java

@@ -1401,7 +1401,8 @@ private void runKeyCommitTooLargeExceptionTest(
                 1, "large_key", DEFAULT_SHARDING_KEY, largeCommit.getEstimatedWorkItemCommitBytes())
             .build(),
         removeDynamicFields(largeCommit));
-    // Check this explicitly since the estimated commit bytes weren't actuallyExpand commentComment on line L1340
+    // Check this explicitly since the estimated commit bytes weren't actuallyExpand commentComment
+    // on line L1340
     // checked against an expected value in the previous step
     assertTrue(largeCommit.getEstimatedWorkItemCommitBytes() > 1000);