You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ja...@apache.org on 2024/05/25 15:31:10 UTC
(beam) 01/01: Merge pull request #31394: #31112 drop flink 1.14
This is an automated email from the ASF dual-hosted git repository.
janl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0790d698251f82809c5f4cecaaef5e74c316a0eb
Merge: cf3592bbfa0 c10f5d40456
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Sat May 25 17:31:02 2024 +0200
Merge pull request #31394: #31112 drop flink 1.14
.../test-properties.json | 2 +-
gradle.properties | 2 +-
.../runner-concepts/description.md | 2 +-
runners/flink/1.14/build.gradle | 25 ------
.../flink/1.14/job-server-container/build.gradle | 26 -------
runners/flink/1.14/job-server/build.gradle | 31 --------
.../streaming/AbstractStreamOperatorCompat.java | 91 ----------------------
.../streaming/ProcessingTimeCallbackCompat.java | 22 ------
.../io/source/compat/FlinkSourceCompat.java | 28 -------
.../io/source/compat/SplitEnumeratorCompat.java | 27 -------
.../streaming/io/source/compat/package-info.java | 20 -----
.../beam/runners/flink/MiniClusterCompat.java | 29 -------
.../runners/flink/metrics/MetricGroupWrapper.java | 31 --------
.../translation/types/CoderTypeSerializer.java | 0
.../streaming/ProcessingTimeCallbackCompat.java | 22 ------
.../beam/runners/flink/MiniClusterCompat.java | 30 -------
.../flink/FlinkStreamingTransformTranslators.java | 8 +-
.../wrappers/streaming/DoFnOperator.java | 57 ++++++++++++--
.../streaming/io/UnboundedSourceWrapper.java | 8 +-
.../streaming/io/source/FlinkSourceReaderBase.java | 3 +-
.../io/source/FlinkSourceSplitEnumerator.java | 9 +--
.../beam/runners/flink/FlinkSavepointTest.java | 6 +-
.../beam/runners/flink/RemoteMiniClusterImpl.java | 0
.../flink/metrics/FlinkMetricContainerTest.java | 3 +-
.../runners/flink/streaming/StreamSources.java | 0
.../translation/types/CoderTypeSerializerTest.java | 0
.../streaming/io/UnboundedSourceWrapperTest.java | 4 +-
.../io/source/FlinkSourceReaderTestBase.java | 20 ++---
.../streaming/io/source/SourceTestMetrics.java} | 2 +-
.../bounded/FlinkBoundedSourceReaderTest.java | 2 +-
.../unbounded/FlinkUnboundedSourceReaderTest.java | 2 +-
sdks/go/examples/wasm/README.md | 2 +-
.../python/apache_beam/options/pipeline_options.py | 2 +-
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
settings.gradle.kts | 4 -
.../site/content/en/documentation/runners/flink.md | 9 ++-
.../shortcodes/flink_java_pipeline_options.html | 10 +++
.../shortcodes/flink_python_pipeline_options.html | 10 +++
38 files changed, 115 insertions(+), 436 deletions(-)