This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 17beb66858b6fc21dcd52215e8407286faf4b535
Merge: 2ab6c8a 730e7c0
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Fri Nov 13 12:40:08 2020 +0100
Merge pull request #13282: [BEAM-11172] Enable KafkaIO performance test for
Dataflow runner v2 with SDF.
.../jenkins/job_PerformanceTests_KafkaIO_IT.groovy | 48 ++++++++++++-
.../kafka-cluster/05-kafka/configmap-config.yaml | 4 ++
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 67 +++++++++++++-----
runners/google-cloud-dataflow-java/build.gradle | 47 +++++--------
.../examples/build.gradle | 2 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 14 +++-
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 81 +++++++++++++++++++---
7 files changed, 199 insertions(+), 64 deletions(-)
