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 3930d12 (commit)
to edeaf67 (commit)
from 3930d12 Merge pull request #13981: [BEAM-11124] bump joda-time to
2.10.10
add f53bfee Move payload providers out into their own module. (#13963)
add 0566418 Removed conscrypt from a shaded dataflow-worker jar (#13846)
add 09e65cb [BEAM-11747] Reject the mixed Java UDF and ZetaSQL builtin
operator cases (#13912)
add c9b60bc Minor fixes for python nexmark benchmarks
add d9d1daf Merge pull request #13969 from Minor fixes for python nexmark
benchmarks
add 5996801 [BEAM-11589] Migrated release build.gradle file to Kotlin
script (#13948)
add 7b4962e [BEAM-11811] [Dataflow Java] Don't allow numWorkers >
maxNumWorkers.
add cbe2b9c Don't create unassigned variable.
add fac5f97 Merge pull request #13989 from ibzib/BEAM-11811
add b4413d6 Bump dataflow container version (#13988)
add c8cc2a3 [BEAM-11779] Fix dataflow URL printed by Go. (#13997)
add 130e60e [BEAM-11415] Fix misc. bugs affecting Go XLang tests.
add edeaf67 Merge pull request #13999: [BEAM-11415] Fix misc. bugs
affecting Go XLang tests.
No new revisions were added by this update.
Summary of changes:
release/{build.gradle => build.gradle.kts} | 29 ++++---
.../dataflow/DataflowPipelineTranslator.java | 7 ++
.../dataflow/DataflowPipelineTranslatorTest.java | 25 ++++++
.../google-cloud-dataflow-java/worker/build.gradle | 6 +-
.../worker/legacy-worker/build.gradle | 13 ++--
sdks/go/pkg/beam/core/runtime/xlangx/expand.go | 8 +-
.../beam/runners/dataflow/dataflowlib/execute.go | 2 +-
sdks/go/test/integration/primitives/cogbk_test.go | 2 +
.../v1/gen.go => test/integration/xlang/xlang.go} | 5 +-
sdks/go/test/run_validatesrunner_tests.sh | 2 +-
.../src/main/resources/beam/suppressions.xml | 2 +-
sdks/java/extensions/protobuf/build.gradle | 1 +
.../protobuf}/ProtoPayloadSerializerProvider.java | 3 +-
.../ProtoPayloadSerializerProviderTest.java | 15 ++--
.../src/test/proto/payload_messages.proto} | 2 +-
sdks/java/extensions/sql/build.gradle | 7 +-
.../sql/meta/provider/payloads/package-info.java | 24 ------
.../provider/kafka/BeamKafkaTableProtoTest.java | 7 +-
.../provider/kafka/BeamKafkaTableThriftTest.java | 2 +-
.../meta/provider/kafka/KafkaTableProviderIT.java | 7 +-
.../provider/kafka/KafkaTableProviderTest.java | 5 +-
.../sql/zetasql/BeamJavaUdfCalcRule.java | 2 +-
.../sql/zetasql/BeamZetaSqlCalcRule.java | 2 +-
.../sql/zetasql/ZetaSQLQueryPlanner.java | 48 ++++++++++--
.../extensions/sql/zetasql/ZetaSqlJavaUdfTest.java | 14 ++--
sdks/java/io/thrift/build.gradle | 1 +
.../thrift}/ThriftPayloadSerializerProvider.java | 5 +-
.../ThriftPayloadSerializerProviderTest.java | 4 +-
.../sdk/io/thrift/payloads}/ItThriftMessage.java | 56 +++++++-------
.../io/thrift/payloads}/SimpleThriftMessage.java | 51 ++++++------
.../sdk/io/thrift/payloads}/TestThriftMessage.java | 90 +++++++++++-----------
.../sdk/io/thrift/payloads}/thrift_test.thrift | 0
.../thrift/src/test/thrift/payload.thrift} | 6 +-
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
.../testing/benchmarks/nexmark/nexmark_launcher.py | 10 ++-
.../testing/benchmarks/nexmark/queries/query0.py | 2 +-
.../testing/benchmarks/nexmark/queries/query1.py | 2 +-
.../testing/benchmarks/nexmark/queries/query10.py | 4 +-
.../testing/benchmarks/nexmark/queries/query11.py | 2 +-
.../testing/benchmarks/nexmark/queries/query12.py | 2 +-
.../testing/benchmarks/nexmark/queries/query2.py | 2 +-
.../testing/benchmarks/nexmark/queries/query3.py | 2 +-
.../testing/benchmarks/nexmark/queries/query4.py | 2 +-
.../testing/benchmarks/nexmark/queries/query5.py | 2 +-
.../testing/benchmarks/nexmark/queries/query6.py | 2 +-
.../testing/benchmarks/nexmark/queries/query7.py | 2 +-
.../testing/benchmarks/nexmark/queries/query8.py | 2 +-
.../testing/benchmarks/nexmark/queries/query9.py | 2 +-
settings.gradle.kts | 1 +
49 files changed, 274 insertions(+), 222 deletions(-)
rename release/{build.gradle => build.gradle.kts} (53%)
copy sdks/go/{pkg/beam/core/runtime/graphx/v1/gen.go =>
test/integration/xlang/xlang.go} (89%)
rename
sdks/java/extensions/{sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/payloads
=>
protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf}/ProtoPayloadSerializerProvider.java
(96%)
rename
sdks/java/extensions/{sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/payloads
=>
protobuf/src/test/java/org/apache/beam/sdk/extensions/protobuf}/ProtoPayloadSerializerProviderTest.java
(85%)
rename sdks/java/extensions/{sql/src/test/proto/kafka/kafka_messages.proto =>
protobuf/src/test/proto/payload_messages.proto} (93%)
delete mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/payloads/package-info.java
rename
sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/payloads
=>
io/thrift/src/main/java/org/apache/beam/sdk/io/thrift}/ThriftPayloadSerializerProvider.java
(96%)
rename
sdks/java/{extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/payloads
=>
io/thrift/src/test/java/org/apache/beam/sdk/io/thrift}/ThriftPayloadSerializerProviderTest.java
(97%)
rename
sdks/java/{extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift
=>
io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/payloads}/ItThriftMessage.java
(90%)
rename
sdks/java/{extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift
=>
io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/payloads}/SimpleThriftMessage.java
(90%)
rename
sdks/java/{extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift
=>
io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/payloads}/TestThriftMessage.java
(90%)
rename sdks/java/io/thrift/src/test/resources/{thrift =>
org/apache/beam/sdk/io/thrift/payloads}/thrift_test.thrift (100%)
rename sdks/java/{extensions/sql/src/test/thrift/kafka/messages.thrift =>
io/thrift/src/test/thrift/payload.thrift} (86%)
