Skip to content

Remove cancelIfTimeouted on writePipeline

40a63f8
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Open

[KafkaIO] Make ReadFromKafkaDoFn restriction trackers unsplittable #36935

Remove cancelIfTimeouted on writePipeline
40a63f8
Select commit
Loading
Failed to load commit list.

Annotations

7 warnings
beam_PreCommit_Java_Kafka_IO_Direct (Run Java_Kafka_IO_Direct PreCommit)
succeeded Dec 1, 2025 in 28m 50s