beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (4f0ea5f -> d0c3dd7)
Date Thu, 03 Jun 2021 03:33:19 GMT
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from 4f0ea5f  (commit)
      to d0c3dd7  (commit)
    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
     add 511fb05  Merge pull request #14906: [BEAM-12281] Drop support for Flink 1.10
     add 934622d  [BEAM-12417] Add UnknownLogicalType to Java for passing through unknown
types from other SDKs (#14904)
     add afeae3c  Minor: Add problematic path to error message (#14903)
     add ed8554d  [BEAM-12104] Java WordCountIT (Dataflow runner) on Ubuntu 20.04 GHA image
(#14915)
     add d0c3dd7  Twitter redesign to move the component to it's separate project. (#14902)

No new revisions were added by this update.

Summary of changes:
 .github/workflows/java_tests.yml                   |  13 ++-
 .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 +
 build.gradle.kts                                   |   1 +
 examples/java/build.gradle                         |   2 -
 examples/java/twitter/build.gradle                 | 105 ++++++++++++++++++++
 .../examples}/twitterstreamgenerator/README.md     |   1 +
 .../ReadFromTwitterDoFn.java                       |   2 +-
 .../twitterstreamgenerator/TwitterConfig.java      |   2 +-
 .../twitterstreamgenerator/TwitterConnection.java  |   2 +-
 .../twitterstreamgenerator/TwitterIO.java          |   2 +-
 .../twitterstreamgenerator/TwitterStream.java      |   2 +-
 .../twitterstreamgenerator/package-info.java       |   2 +-
 .../ReadFromTwitterDoFnTest.java                   |   2 +-
 gradle.properties                                  |   2 +-
 release/build.gradle.kts                           |   2 +-
 release/src/main/scripts/run_rc_validation.sh      |   2 +-
 .../core/construction/SchemaTranslationTest.java   | 110 +++++++++++++++++++++
 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 +-
 .../apache/beam/sdk/schemas/SchemaTranslation.java |  32 +++++-
 .../schemas/logicaltypes/UnknownLogicalType.java   |  49 +++++++++
 sdks/java/io/hadoop-format/build.gradle            |   2 +
 sdks/java/testing/nexmark/build.gradle             |   2 +-
 sdks/java/testing/tpcds/build.gradle               |   2 +-
 sdks/python/apache_beam/io/gcp/gcsio.py            |   4 +-
 sdks/python/apache_beam/transforms/sql_test.py     |   4 +-
 settings.gradle.kts                                |   5 +-
 .../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 +-
 58 files changed, 377 insertions(+), 369 deletions(-)
 create mode 100644 examples/java/twitter/build.gradle
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/README.md
(97%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/ReadFromTwitterDoFn.java
(99%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterConfig.java
(98%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterConnection.java
(98%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterIO.java
(98%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/TwitterStream.java
(98%)
 rename examples/java/{src/main/java/org/apache/beam/examples/complete => twitter/src/main/java/org/apache/beam/examples}/twitterstreamgenerator/package-info.java
(92%)
 rename examples/java/{src/test/java/org/apache/beam/examples/complete => twitter/src/test/java/org/apache/beam/examples}/twitterstreamgenerator/ReadFromTwitterDoFnTest.java
(98%)
 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%)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/UnknownLogicalType.java

Mime
View raw message