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%)