This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from cf3592bbfa0 Fix an incompatibility with hamcrest 2.2 (#31395)
add c10f5d40456 [runners-flink] Drop Flnk 1.14 and clean up code (#31112)
add 0790d698251 Merge pull request #31394: #31112 drop flink 1.14
add 5a822adc269 [flink] #31390 emit watermark with empty source
add 836e77e755b Merge pull request #31391: [flink] #31390 emit watermark
with empty source
No new revisions were added by this update.
Summary of changes:
.../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 | 12 +--
.../io/source/FlinkSourceSplitEnumerator.java | 9 +--
.../unbounded/FlinkUnboundedSourceReader.java | 8 +-
.../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 +-
.../streaming/io/source/EmptyUnboundedSource.java | 4 +-
.../io/source/FlinkSourceReaderTestBase.java | 20 ++---
.../streaming/io/source/SourceTestMetrics.java} | 2 +-
.../bounded/FlinkBoundedSourceReaderTest.java | 2 +-
.../unbounded/FlinkUnboundedSourceReaderTest.java | 56 ++++++++++++-
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 +++
40 files changed, 178 insertions(+), 448 deletions(-)
delete mode 100644 runners/flink/1.14/build.gradle
delete mode 100644 runners/flink/1.14/job-server-container/build.gradle
delete mode 100644 runners/flink/1.14/job-server/build.gradle
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/FlinkSourceCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/SplitEnumeratorCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/package-info.java
delete mode 100644
runners/flink/1.14/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java
delete mode 100644
runners/flink/1.14/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java
rename runners/flink/{1.14 =>
1.15}/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java
(100%)
delete mode 100644
runners/flink/1.15/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java
delete mode 100644
runners/flink/1.15/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java (100%)
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(100%)
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializerTest.java
(100%)
rename
runners/flink/{1.14/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestCompat.java
=>
src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestMetrics.java}
(99%)
