This is an automated email from the ASF dual-hosted git repository. heejong pushed a change to branch release-2.30.0 in repository https://gitbox.apache.org/repos/asf/beam.git.
from 25cfd35 Merge pull request #14847 from suztomo/cherry-pick-14833 new de8f559 [BEAM-10670] Use non-SDF based translation for Read by default on all runners except Dataflow new dfcfb40 Fix Kafka expansion issues introduced by PR14801 new ca8f378 Merge pull request #14844 from boyuanzz/cherrypick The 31883 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../runners/core/construction/SplittableParDo.java | 4 +++- .../org/apache/beam/runners/direct/DirectRunner.java | 1 + .../org/apache/beam/runners/flink/FlinkRunner.java | 8 +++++++- .../org/apache/beam/runners/samza/SamzaRunner.java | 8 +++++++- .../SparkStructuredStreamingRunner.java | 11 +++++------ runners/spark/spark_runner.gradle | 1 - .../org/apache/beam/runners/spark/SparkRunner.java | 10 ++++------ .../apache/beam/runners/spark/SparkRunnerDebugger.java | 10 ++++------ .../apache/beam/runners/twister2/Twister2Runner.java | 17 ++++++++++++++++- .../src/test/java/org/apache/beam/sdk/io/ReadTest.java | 4 ++++ .../beam/sdk/transforms/GroupIntoBatchesTest.java | 5 ++++- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 18 +++++++++++++++++- 12 files changed, 72 insertions(+), 25 deletions(-)