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(-)
