Skip to content

Commit 9dab803

Browse files
committed
respond to comments
1 parent f6a5931 commit 9dab803

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1401,8 +1401,7 @@ private void runKeyCommitTooLargeExceptionTest(
14011401
1, "large_key", DEFAULT_SHARDING_KEY, largeCommit.getEstimatedWorkItemCommitBytes())
14021402
.build(),
14031403
removeDynamicFields(largeCommit));
1404-
// Check this explicitly since the estimated commit bytes weren't actuallyExpand commentComment
1405-
// on line L1340
1404+
// Check this explicitly since the estimated commit bytes weren't actually
14061405
// checked against an expected value in the previous step
14071406
assertTrue(largeCommit.getEstimatedWorkItemCommitBytes() > 1000);
14081407

0 commit comments

Comments
 (0)