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 4f0ea5f (commit)
to d0c3dd7 (commit)
from 4f0ea5f Merge pull request #14911 from
TheNeuralBit/dataframe-changes-230
add bed7982 [BEAM-12281] Drop support for Flink 1.10
add 22575c7 [BEAM-12281] Update Flink Jenkins jobs to use Flink 1.12
add 511fb05 Merge pull request #14906: [BEAM-12281] Drop support for
Flink 1.10
add 934622d [BEAM-12417] Add UnknownLogicalType to Java for passing
through unknown types from other SDKs (#14904)
add afeae3c Minor: Add problematic path to error message (#14903)
add ed8554d [BEAM-12104] Java WordCountIT (Dataflow runner) on Ubuntu
20.04 GHA image (#14915)
add d0c3dd7 Twitter redesign to move the component to it's separate
project. (#14902)
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_tests.yml | 13 ++-
.test-infra/dataproc/flink_cluster.sh | 2 +-
.test-infra/jenkins/Flink.groovy | 4 +-
.../jenkins/job_LoadTests_Combine_Flink_Go.groovy | 2 +-
.../job_LoadTests_Combine_Flink_Python.groovy | 2 +-
.../jenkins/job_LoadTests_GBK_Flink_Go.groovy | 2 +-
.../jenkins/job_LoadTests_GBK_Flink_Python.groovy | 2 +-
.../jenkins/job_LoadTests_ParDo_Flink_Go.groovy | 2 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 2 +-
.../job_LoadTests_SideInput_Flink_Go.groovy | 2 +-
.../jenkins/job_LoadTests_coGBK_Flink_Go.groovy | 2 +-
.../job_LoadTests_coGBK_Flink_Python.groovy | 2 +-
...Commit_Python_Chicago_Taxi_Example_Flink.groovy | 2 +-
CHANGES.md | 1 +
build.gradle.kts | 1 +
examples/java/build.gradle | 2 -
examples/java/twitter/build.gradle | 105 ++++++++++++++++++++
.../examples}/twitterstreamgenerator/README.md | 1 +
.../ReadFromTwitterDoFn.java | 2 +-
.../twitterstreamgenerator/TwitterConfig.java | 2 +-
.../twitterstreamgenerator/TwitterConnection.java | 2 +-
.../twitterstreamgenerator/TwitterIO.java | 2 +-
.../twitterstreamgenerator/TwitterStream.java | 2 +-
.../twitterstreamgenerator/package-info.java | 2 +-
.../ReadFromTwitterDoFnTest.java | 2 +-
gradle.properties | 2 +-
release/build.gradle.kts | 2 +-
release/src/main/scripts/run_rc_validation.sh | 2 +-
.../core/construction/SchemaTranslationTest.java | 110 +++++++++++++++++++++
runners/flink/1.10/build.gradle | 33 -------
.../flink/1.10/job-server-container/build.gradle | 26 -----
runners/flink/1.10/job-server/build.gradle | 31 ------
.../streaming/AbstractStreamOperatorCompat.java | 30 ------
.../beam/runners/flink/FlinkRunnerTestCompat.java | 42 --------
.../beam/runners/flink/RemoteMiniClusterImpl.java | 71 -------------
.../runners/flink/SourceTransformationCompat.java | 28 ------
runners/flink/1.11/build.gradle | 4 +-
.../runners/flink/streaming/StreamSources.java | 0
runners/flink/1.12/build.gradle | 4 +-
runners/flink/1.13/build.gradle | 4 +-
runners/flink/flink_runner.gradle | 2 +-
.../beam/runners/flink/FlinkPipelineRunner.java | 7 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 7 +-
.../flink/FlinkExecutionEnvironmentsTest.java | 34 ++-----
.../FlinkPipelineExecutionEnvironmentTest.java | 22 ++---
sdks/go/examples/stringsplit/stringsplit.go | 2 +-
.../apache/beam/sdk/schemas/SchemaTranslation.java | 32 +++++-
.../schemas/logicaltypes/UnknownLogicalType.java | 49 +++++++++
sdks/java/io/hadoop-format/build.gradle | 2 +
sdks/java/testing/nexmark/build.gradle | 2 +-
sdks/java/testing/tpcds/build.gradle | 2 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 4 +-
sdks/python/apache_beam/transforms/sql_test.py | 4 +-
settings.gradle.kts | 5 +-
.../site/content/en/contribute/release-guide.md | 2 +-
.../content/en/documentation/dsls/sql/shell.md | 6 +-
.../site/content/en/documentation/runners/flink.md | 6 +-
.../en/documentation/sdks/java/testing/nexmark.md | 6 +-
58 files changed, 377 insertions(+), 369 deletions(-)
create mode 100644 examples/java/twitter/build.gradle
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/README.md
(97%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/ReadFromTwitterDoFn.java
(99%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterConfig.java
(98%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterConnection.java
(98%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterIO.java
(98%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterStream.java
(98%)
rename examples/java/{src/main/java/org/apache/beam/examples/complete =>
twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/package-info.java
(92%)
rename examples/java/{src/test/java/org/apache/beam/examples/complete =>
twitter/src/test/java/org/apache/beam/examples}/twitterstreamgenerator/ReadFromTwitterDoFnTest.java
(98%)
delete mode 100644 runners/flink/1.10/build.gradle
delete mode 100644 runners/flink/1.10/job-server-container/build.gradle
delete mode 100644 runners/flink/1.10/job-server/build.gradle
delete mode 100644
runners/flink/1.10/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
delete mode 100644
runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
delete mode 100644
runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java
delete mode 100644
runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java
rename runners/flink/{1.10 =>
1.11}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(100%)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/UnknownLogicalType.java
