Skip to content

Commit 40a63f8

Browse files
committed
Remove cancelIfTimeouted on writePipeline
1 parent 5b502ff commit 40a63f8

File tree

1 file changed

+0
-1
lines changed
  • sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka

1 file changed

+0
-1
lines changed

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOIT.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -824,7 +824,6 @@ public void testKafkaWithStopReadTime() throws IOException {
824824

825825
PipelineResult writeResult = writePipeline.run();
826826
PipelineResult.State writeState = writeResult.waitUntilFinish();
827-
cancelIfTimeouted(writeResult, writeState);
828827
assertNotEquals(PipelineResult.State.FAILED, writeState);
829828

830829
sdfReadPipeline.getOptions().as(Options.class).setStreaming(false);

0 commit comments

Comments
 (0)