From f3578ae1de1f9f7d898922462714a547b1241113 Mon Sep 17 00:00:00 2001 From: Tom Stepp Date: Thu, 7 Aug 2025 12:02:01 -0700 Subject: [PATCH 1/3] Remove no-parallel flag on kafka IO direct precommit --- .github/workflows/beam_PreCommit_Java_Kafka_IO_Direct.yml | 1 - 1 file changed, 1 deletion(-) diff --git a/.github/workflows/beam_PreCommit_Java_Kafka_IO_Direct.yml b/.github/workflows/beam_PreCommit_Java_Kafka_IO_Direct.yml index 72dcb3f2bd29..87676c9626bb 100644 --- a/.github/workflows/beam_PreCommit_Java_Kafka_IO_Direct.yml +++ b/.github/workflows/beam_PreCommit_Java_Kafka_IO_Direct.yml @@ -100,7 +100,6 @@ jobs: arguments: | -PdisableSpotlessCheck=true \ -PdisableCheckStyle=true \ - --no-parallel \ - name: Archive JUnit Test Results uses: actions/upload-artifact@v4 if: ${{ !success() }} From f5e044a020597728d51e65d30baeeb0338cf0074 Mon Sep 17 00:00:00 2001 From: Tom Stepp Date: Thu, 7 Aug 2025 12:11:17 -0700 Subject: [PATCH 2/3] Temp change to trigger precommit run. --- .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index bbe20b1ed63a..deeadba0b73a 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -1093,6 +1093,8 @@ public Read withTopicPartitions(List topicPartitions) { /** * Sets redistribute transform that hints to the runner to try to redistribute the work evenly. + * + * @return an updated {@link Read} transform. */ public Read withRedistribute() { return toBuilder().setRedistributed(true).build(); From f6b9d6fcc849ea9c2816f157a4b001387c3abadb Mon Sep 17 00:00:00 2001 From: Tom Stepp Date: Thu, 7 Aug 2025 12:41:56 -0700 Subject: [PATCH 3/3] Remove temp change --- .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index deeadba0b73a..bbe20b1ed63a 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -1093,8 +1093,6 @@ public Read withTopicPartitions(List topicPartitions) { /** * Sets redistribute transform that hints to the runner to try to redistribute the work evenly. - * - * @return an updated {@link Read} transform. */ public Read withRedistribute() { return toBuilder().setRedistributed(true).build();