This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0a663cd Merge pull request #1109: [BEAM-9479] Add pre-commit hook for
pylint
add f91b390 [BEAM-9295] Add Flink 1.10 build target and Make FlinkRunner
compatible with Flink 1.10
add be8b4ff Merge pull request #10945: [BEAM-9295] Add Flink 1.10 build
target and Make FlinkRunner compatible with Flink 1.10
No new revisions were added by this update.
Summary of changes:
.test-infra/dataproc/flink_cluster.sh | 4 +-
.test-infra/jenkins/CommonTestProperties.groovy | 2 +-
.test-infra/jenkins/Flink.groovy | 4 +-
.../job_LoadTests_Combine_Flink_Python.groovy | 4 +-
.../jenkins/job_LoadTests_GBK_Flink_Python.groovy | 4 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 4 +-
.../job_LoadTests_coGBK_Flink_Python.groovy | 4 +-
...ommit_CrossLanguageValidatesRunner_Flink.groovy | 4 +-
.../job_PostCommit_Java_Nexmark_Flink.groovy | 8 +-
...Java_PortableValidatesRunner_Flink_Batch.groovy | 2 +-
..._PortableValidatesRunner_Flink_Streaming.groovy | 2 +-
...ob_PostCommit_Java_ValidatesRunner_Flink.groovy | 2 +-
.../job_PostCommit_PortableJar_Flink.groovy | 2 +-
...Commit_Python_Chicago_Taxi_Example_Flink.groovy | 4 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
examples/java/build.gradle | 2 +-
examples/kotlin/build.gradle | 2 +-
release/build.gradle | 2 +-
.../src/main/scripts/build_release_candidate.sh | 2 +-
release/src/main/scripts/run_rc_validation.sh | 2 +-
runners/flink/{1.9 => 1.10}/build.gradle | 8 +-
.../job-server-container/build.gradle | 0
.../flink/{1.7 => 1.10}/job-server/build.gradle | 2 +-
.../flink/BeamFlinkRemoteStreamEnvironment.java | 21 +++-
.../apache/beam/runners/flink/FlinkRunnerTest.java | 17 ++--
.../runners/flink/streaming/StreamSources.java | 10 +-
.../flink/BeamFlinkRemoteStreamEnvironment.java | 112 +++++++++++++++++++++
.../apache/beam/runners/flink/FlinkRunnerTest.java | 0
runners/flink/flink_runner.gradle | 6 +-
.../runners/flink/FlinkExecutionEnvironments.java | 91 ++---------------
.../beam/runners/flink/FlinkPipelineRunner.java | 9 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 9 +-
.../flink/FlinkExecutionEnvironmentsTest.java | 83 ++++++++-------
.../FlinkPipelineExecutionEnvironmentTest.java | 55 +++++++---
.../flink/FlinkRequiresStableInputTest.java | 13 ++-
.../beam/runners/flink/FlinkSavepointTest.java | 5 +-
.../beam/runners/flink/FlinkSubmissionTest.java | 3 +-
sdks/go/test/build.gradle | 4 +-
.../src/main/resources/beam/suppressions.xml | 1 +
sdks/java/maven-archetypes/examples/build.gradle | 2 +-
sdks/java/testing/nexmark/build.gradle | 2 +-
sdks/python/test-suites/portable/common.gradle | 8 +-
sdks/python/test-suites/portable/py2/build.gradle | 14 +--
sdks/python/test-suites/portable/py35/build.gradle | 6 +-
sdks/python/test-suites/portable/py36/build.gradle | 6 +-
sdks/python/test-suites/portable/py37/build.gradle | 6 +-
settings.gradle | 4 +
website/src/contribute/release-guide.md | 4 +-
website/src/documentation/dsls/sql/shell.md | 6 +-
website/src/documentation/runners/flink.md | 19 +++-
website/src/documentation/sdks/nexmark.md | 6 +-
51 files changed, 369 insertions(+), 231 deletions(-)
copy runners/flink/{1.9 => 1.10}/build.gradle (84%)
copy runners/flink/{1.9 => 1.10}/job-server-container/build.gradle (100%)
copy runners/flink/{1.7 => 1.10}/job-server/build.gradle (95%)
copy
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/package-info.java
=>
runners/flink/1.10/src/main/java/org/apache/beam/runners/flink/BeamFlinkRemoteStreamEnvironment.java
(55%)
copy runners/flink/{ =>
1.10}/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java (86%)
copy runners/flink/{1.9 =>
1.10}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(85%)
create mode 100644
runners/flink/1.7/src/main/java/org/apache/beam/runners/flink/BeamFlinkRemoteStreamEnvironment.java
rename runners/flink/{ =>
1.7}/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java (100%)
