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ý <[email protected]> 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(-)
