This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 24179c3 (commit)
to 809a0b7 (commit)
from 24179c3 Merge pull request #13790 from Remove boilerplate notes from
2.27.0
add aa57b51 [BEAM-10402] Add nullability annotations to SplitResult.of
add 8194761 Merge pull request #13769 from [BEAM-10402] Add nullability
annotations to SplitResult.of
add 04ae01c Expose commit_offset_in_finalize and timestamp_policy to
ReadFromKafka.
add 8b759d1 Merge pull request #13779 from [BEAM-11677] Expose
commit_offset_in_finalize and timestamp_policy to ReadFromKafka
add 262273c [BEAM-10961] Enabled strict Dependency on Portability (#13666)
add 4141550 [BEAM-10961] Enabled strict dependencies on example module
(#13649)
add 5d58250 [BEAM-10961] enabled strict dependency on sdks-core and
sdks-expansion-service (#13685)
add cf402a1 [BEAM-10961] Enabled strict dependency on SDKS-Testing
(#13689)
add 0460daa [BEAM-10961] Enabled strict dependency on Jet Runner (#13663)
add da2f431 [BEAM-11570] Disable classloader check for [auto] mode.
(#13722)
add 52dcc36 [BEAM-10961] Enabled strict dependency on Direct Java runner
(#13656)
add 9e0920c [BEAM-11542] Add support for projecting GroupBy objects
(#13637)
add d7bee01 strict dependency for some sdks/java/io modules - trivial
changes (#13794)
add 9bc7820 [BEAM-9541] Jenkins tests use latest Flink version.
add 704bae9 Write latest Flink version in CommonTestProperties.
add 809a0b7 Merge pull request #13675 from ibzib/flink-jenkins
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/CommonTestProperties.groovy | 6 +-
...ommit_CrossLanguageValidatesRunner_Flink.groovy | 3 +-
.../job_PostCommit_Java_Nexmark_Flink.groovy | 13 +--
...Java_PortableValidatesRunner_Flink_Batch.groovy | 3 +-
..._PortableValidatesRunner_Flink_Streaming.groovy | 5 +-
...ob_PostCommit_Java_ValidatesRunner_Flink.groovy | 3 +-
...Commit_Java_ValidatesRunner_Flink_Java11.groovy | 7 +-
.../jenkins/job_Publish_Docker_Snapshots.groovy | 3 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +
examples/java/build.gradle | 13 ++-
examples/kotlin/build.gradle | 14 ++--
runners/direct-java/build.gradle | 14 ++--
.../runners/flink/FlinkExecutionEnvironments.java | 15 +++-
runners/jet/build.gradle | 8 +-
runners/portability/java/build.gradle | 11 ++-
.../container/license_scripts/dep_urls_java.yaml | 4 +-
sdks/java/core/build.gradle | 5 +-
.../sdk/transforms/splittabledofn/SplitResult.java | 2 +-
sdks/java/expansion-service/build.gradle | 3 +-
sdks/java/io/amqp/build.gradle | 4 +-
sdks/java/io/cassandra/build.gradle | 1 +
sdks/java/io/common/build.gradle | 2 +-
.../elasticsearch-tests-2/build.gradle | 1 +
.../elasticsearch-tests-5/build.gradle | 1 +
.../elasticsearch-tests-6/build.gradle | 1 +
.../elasticsearch-tests-7/build.gradle | 1 +
.../elasticsearch-tests-common/build.gradle | 1 +
sdks/java/io/hadoop-common/build.gradle | 4 +-
sdks/java/io/hadoop-file-system/build.gradle | 4 +-
sdks/java/io/hbase/build.gradle | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 29 ++++++-
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 6 +-
sdks/java/io/kudu/build.gradle | 3 +-
sdks/java/io/mongodb/build.gradle | 4 +-
sdks/java/io/rabbitmq/build.gradle | 4 +-
sdks/java/io/redis/build.gradle | 4 +-
sdks/java/testing/expansion-service/build.gradle | 7 +-
sdks/java/testing/jpms-tests/build.gradle | 2 +-
sdks/java/testing/kafka-service/build.gradle | 2 +-
sdks/java/testing/load-tests/build.gradle | 8 +-
sdks/java/testing/nexmark/build.gradle | 9 +--
sdks/java/testing/test-utils/build.gradle | 12 ++-
sdks/python/apache_beam/dataframe/frames.py | 82 ++++++++++++++-----
sdks/python/apache_beam/dataframe/frames_test.py | 93 ++++++++++++++++++----
sdks/python/apache_beam/io/kafka.py | 34 +++++---
.../runners/portability/flink_runner_test.py | 5 +-
46 files changed, 332 insertions(+), 130 deletions(-)
