You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2020/09/30 02:54:06 UTC

[beam] tag nightly-master updated (cee7388 -> 36268e1)

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 cee7388  (commit)
      to 36268e1  (commit)
    from cee7388  Merge pull request #12949 [BEAM-10978] Fix bug with map type inference.
     add 531f5c9  [BEAM-10971] Redirect contribute/design-documents to cwiki.
     add 79801d7  Merge pull request #12945 from ibzib/BEAM-10971
     add f75c949  Fix Java nightly snapshot build.
     add c9547cc  Merge pull request #12947: [Beam-10903] Fix Java nightly snapshot build.
     add 245cf2b  [BEAM-8024] Add JPMS E2E test (#12899)
     add 029c26d  [BEAM-10953] Add errorprone-slf4j plugin.
     add db63f60  [BEAM-10953] Fix errorprone-slf4j errors.
     add 7c43ab6  Merge pull request #12907 from ibzib/BEAM-10953
     add 5e9547f  Fix failed GroupIntoBatchesOverrideTest
     add d905924  Merge pull request #12961 Fix failing GroupIntoBatchesOverrideTest
     add 97a270f  [BEAM-8106] Add version to java container image name (#12505)
     add c5225bd  Adds duration string to the ib.show and ib.collect
     add 847aa82  Merge pull request #12967 from [BEAM-10956] Adds duration string to the ib.show and ib.collect
     add db4e126  [BEAM-10677] Fix @SchemaFieldName in AutoValueSchema (#12520)
     add 9e33bf8  Remove experimental declarations from fileio.
     add 36268e1  Merge pull request #12873 Remove experimental declarations from fileio.

No new revisions were added by this update.

Summary of changes:
 ...oovy => job_PostCommit_Java_Jpms_Java11.groovy} | 10 ++---
 ..._PreCommit_Java_Examples_Dataflow_Java11.groovy |  2 +-
 ...job_PreCommit_Java_PortabilityApi_Java11.groovy |  2 +-
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |  6 ++-
 .../examples/subprocess/ExampleEchoPipeline.java   |  4 +-
 .../subprocess/utils/CallingSubProcessUtils.java   |  2 +-
 .../examples/subprocess/utils/ExecutableFile.java  |  2 +-
 .../subprocess/ExampleEchoPipelineTest.java        |  4 +-
 release/src/main/scripts/publish_docker_images.sh  | 29 ++++++------
 .../runners/core/construction/Environments.java    | 52 +++++++++++++++++++---
 .../graph/GreedyPCollectionFusers.java             |  3 +-
 .../core/construction/EnvironmentsTest.java        | 15 +++++++
 .../flink/PipelineTranslationModeOptimizer.java    |  2 +-
 .../translation/wrappers/SourceInputFormat.java    |  2 +-
 .../beam/runners/flink/ReadSourcePortableTest.java |  2 +-
 runners/google-cloud-dataflow-java/build.gradle    |  2 +-
 .../beam/runners/dataflow/DataflowPipelineJob.java |  6 +--
 .../beam/runners/dataflow/DataflowRunner.java      | 13 +++---
 .../beam/runners/dataflow/DataflowRunnerTest.java  | 18 +++-----
 .../dataflow/worker/BatchDataflowWorker.java       |  2 +-
 .../worker/DataflowWorkerHarnessHelper.java        |  1 +
 .../beam/runners/dataflow/worker/HotKeyLogger.java |  2 +-
 .../dataflow/worker/StreamingDataflowWorker.java   |  2 +-
 ...ntMonitoringInfoToCounterUpdateTransformer.java |  3 +-
 ...meMonitoringInfoToCounterUpdateTransformer.java |  3 +-
 ...ntMonitoringInfoToCounterUpdateTransformer.java |  3 +-
 ...onMonitoringInfoToCounterUpdateTransformer.java |  3 +-
 ...erMonitoringInfoToCounterUpdateTransformer.java |  3 +-
 .../worker/fn/logging/BeamFnLoggingService.java    |  2 +-
 .../worker/windmill/GrpcWindmillServer.java        |  6 +--
 .../runners/dataflow/worker/HotKeyLoggerTest.java  |  1 +
 .../worker/windmill/GrpcWindmillServerTest.java    |  2 +-
 .../fnexecution/control/FnApiControlClient.java    |  2 +-
 .../fnexecution/status/WorkerStatusClient.java     |  4 +-
 .../runners/jobsubmission/InMemoryJobService.java  |  4 +-
 .../apache/beam/runners/jet/JetPipelineResult.java |  2 +-
 .../runners/portability/ExternalWorkerService.java |  2 +-
 .../samza/container/BeamContainerRunner.java       |  2 +-
 .../samza/translation/TranslationContext.java      |  2 +-
 sdks/java/bom/build.gradle                         |  9 +++-
 .../src/main/resources/beam/checkstyle.xml         |  7 +++
 sdks/java/container/Dockerfile                     |  6 +--
 sdks/java/container/Dockerfile-java11              | 45 -------------------
 sdks/java/container/build.gradle                   | 14 +++---
 .../java/org/apache/beam/sdk/io/FileBasedSink.java |  3 +-
 .../org/apache/beam/sdk/io/LocalFileSystem.java    |  2 +-
 .../beam/sdk/schemas/utils/AutoValueUtils.java     |  8 +++-
 .../beam/sdk/schemas/utils/ByteBuddyUtils.java     |  2 +-
 .../beam/sdk/transforms/join/CoGbkResult.java      |  6 +--
 .../beam/sdk/schemas/AutoValueSchemaTest.java      | 39 ++++++++++++++++
 .../sdk/extensions/gcp/options/GcpOptions.java     |  2 +-
 .../beam/sdk/extensions/ml/BatchRequestForDLP.java |  2 +-
 .../harness/state/BeamFnStateGrpcClientCache.java  |  3 +-
 .../beam/sdk/io/aws/dynamodb/DynamoDBIO.java       |  2 +-
 .../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java |  2 +-
 .../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java      |  4 +-
 .../org/apache/beam/sdk/io/aws2/sns/SnsIO.java     |  2 +-
 .../beam/sdk/io/gcp/bigquery/BatchLoads.java       |  2 +-
 .../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java  |  2 +-
 .../beam/sdk/io/gcp/bigquery/WriteRename.java      |  2 +-
 .../sdk/io/gcp/bigtable/BigtableServiceImpl.java   |  2 +-
 .../beam/sdk/io/gcp/datastore/EntityToRow.java     |  2 +-
 .../beam/sdk/io/gcp/datastore/RowToEntity.java     |  2 +-
 .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java   |  2 +-
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    |  2 +-
 .../org/apache/beam/sdk/io/kudu/KuduIOTest.java    |  2 +-
 .../synthetic => testing/jpms-tests}/build.gradle  | 42 +++++++++++------
 .../jpms-tests/src/main/java/module-info.java}     |  6 +--
 .../org/apache/beam/sdk/jpmstests}/WordCount.java  | 13 ++++--
 .../apache/beam/sdk/jpmstests}/package-info.java   |  4 +-
 .../java/org/apache/beam/sdk/jpmstests/JpmsIT.java | 24 ++++------
 .../org/apache/beam/sdk/nexmark/NexmarkUtils.java  |  2 +-
 .../apache/beam/sdk/nexmark/queries/Query10.java   | 33 +++++++-------
 .../apache_beam/examples/kafkataxi/README.md       |  4 +-
 sdks/python/apache_beam/io/fileio.py               |  9 ----
 .../runners/interactive/interactive_beam.py        | 31 +++++--------
 .../runners/interactive/recording_manager.py       | 13 ++++--
 .../runners/interactive/recording_manager_test.py  | 34 +++++++++++---
 settings.gradle                                    |  5 ++-
 .../site/content/en/contribute/release-guide.md    |  2 +-
 .../en/documentation/runtime/environments.md       |  4 +-
 website/www/site/static/.htaccess                  |  2 +
 82 files changed, 367 insertions(+), 264 deletions(-)
 copy .test-infra/jenkins/{job_PostCommit_Java.groovy => job_PostCommit_Java_Jpms_Java11.groovy} (81%)
 delete mode 100644 sdks/java/container/Dockerfile-java11
 copy sdks/java/{io/synthetic => testing/jpms-tests}/build.gradle (56%)
 copy sdks/java/{extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/testkit/accumulators/Snapshotable.java => testing/jpms-tests/src/main/java/module-info.java} (86%)
 copy {runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/examples => sdks/java/testing/jpms-tests/src/main/java/org/apache/beam/sdk/jpmstests}/WordCount.java (97%)
 copy sdks/java/testing/{nexmark/src/main/java/org/apache/beam/sdk/nexmark => jpms-tests/src/main/java/org/apache/beam/sdk/jpmstests}/package-info.java (92%)
 copy examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java => sdks/java/testing/jpms-tests/src/test/java/org/apache/beam/sdk/jpmstests/JpmsIT.java (78%)