beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ieme...@apache.org
Subject [beam] branch master updated (4f0ea5f -> 511fb05)
Date Wed, 02 Jun 2021 09:10:00 GMT
This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    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
     new 511fb05  Merge pull request #14906: [BEAM-12281] Drop support for Flink 1.10

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .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 +
 gradle.properties                                  |  2 +-
 release/build.gradle.kts                           |  2 +-
 release/src/main/scripts/run_rc_validation.sh      |  2 +-
 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 +-
 sdks/java/testing/nexmark/build.gradle             |  2 +-
 sdks/java/testing/tpcds/build.gradle               |  2 +-
 sdks/python/apache_beam/transforms/sql_test.py     |  4 +-
 settings.gradle.kts                                |  4 --
 .../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 +-
 41 files changed, 57 insertions(+), 355 deletions(-)
 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%)

Mime
View raw message