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

Co-authored-by: Arun Pandian <arunpandianp@gmail.com>

Author: rwiggles

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

@@ -702,11 +702,11 @@ private void validateCommitRequestSize() {
     long byteLimit = operationalLimits.getMaxWorkItemCommitBytes();
     Windmill.WorkItemCommitRequest commitRequest = currentBuilder.build();
     int commitSize = commitRequest.getSerializedSize();
-    int estimatedCommitSize = commitSize < 0 ? Integer.MAX_VALUE : commitSize;
 
     // Detect overflow of integer serialized size or if the byte limit was exceeded.
     // Commit is too large if overflow has occurred or the commitSize has exceeded the allowed
     // commit byte limit.
+    int estimatedCommitSize = commitSize < 0 ? Integer.MAX_VALUE : commitSize;
     streamingCounters.windmillMaxObservedWorkItemCommitBytes().addValue(estimatedCommitSize);
     if (commitSize >= 0 && commitSize < byteLimit) {
       return;