This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 50a4baa [BEAM-3457] Upgrade version of gogradle and add examples and
containers to :goPrecommit
add f9f9e87 [BEAM-4481, BEAM-4484] Start vendoring portability
dependencies to not have dependency conflicts
new 109f03c [BEAM-4481, BEAM-4484] Start vendoring portability
dependencies to not have dependency conflicts
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:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 138 ++++++++++++++++++++-
examples/java/build.gradle | 2 +-
model/fn-execution/build.gradle | 13 +-
model/job-management/build.gradle | 13 +-
model/pipeline/build.gradle | 7 +-
runners/core-construction-java/build.gradle | 6 +-
.../core/construction/ArtifactServiceStager.java | 6 +-
.../beam/runners/core/construction/BeamUrns.java | 2 +-
.../core/construction/CoderTranslation.java | 2 +-
.../core/construction/CombineTranslation.java | 2 +-
.../CreatePCollectionViewTranslation.java | 2 +-
.../core/construction/DisplayDataTranslation.java | 4 +-
.../runners/core/construction/Environments.java | 2 +-
.../construction/PCollectionViewTranslation.java | 2 +-
.../core/construction/ParDoTranslation.java | 4 +-
.../construction/PipelineOptionsTranslation.java | 4 +-
.../runners/core/construction/ReadTranslation.java | 4 +-
.../core/construction/TestStreamTranslation.java | 2 +-
.../core/construction/WindowIntoTranslation.java | 2 +-
.../construction/WindowingStrategyTranslation.java | 8 +-
.../core/construction/WriteFilesTranslation.java | 2 +-
.../graph/GreedyPCollectionFusers.java | 2 +-
.../core/construction/graph/QueryablePipeline.java | 2 +-
.../construction/ArtifactServiceStagerTest.java | 8 +-
.../InMemoryArtifactStagerService.java | 2 +-
.../PipelineOptionsTranslationTest.java | 6 +-
.../construction/WindowIntoTranslationTest.java | 2 +-
.../construction/graph/ProtoOverridesTest.java | 2 +-
runners/core-java/build.gradle | 2 -
runners/direct-java/build.gradle | 19 ++-
.../runners/direct/portable/ReferenceRunner.java | 2 +-
.../LocalFileSystemArtifactRetrievalService.java | 6 +-
.../LocalFileSystemArtifactStagerService.java | 8 +-
.../runners/direct/portable/job/PreparingJob.java | 2 +-
.../portable/job/ReferenceRunnerJobService.java | 6 +-
...ocalFileSystemArtifactRetrievalServiceTest.java | 4 +-
.../LocalFileSystemArtifactStagerServiceTest.java | 14 +--
.../UnsupportedArtifactRetrievalServiceTest.java | 2 +-
.../job/ReferenceRunnerJobServiceTest.java | 4 +-
.../FlinkBatchPortablePipelineTranslator.java | 2 +-
.../apache/beam/runners/flink/FlinkJobInvoker.java | 2 +-
.../FlinkStreamingPortablePipelineTranslator.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../FlinkExecutableStageFunctionTest.java | 2 +-
.../dataflow/DataflowPipelineTranslator.java | 2 +-
runners/java-fn-execution/build.gradle | 3 -
.../apache/beam/runners/fnexecution/FnService.java | 2 +-
.../GrpcContextHeaderAccessorProvider.java | 16 +--
.../beam/runners/fnexecution/GrpcFnServer.java | 2 +-
.../fnexecution/InProcessServerFactory.java | 8 +-
.../beam/runners/fnexecution/ServerFactory.java | 8 +-
.../BeamFileSystemArtifactRetrievalService.java | 10 +-
.../BeamFileSystemArtifactStagingService.java | 10 +-
.../fnexecution/control/FnApiControlClient.java | 6 +-
.../control/FnApiControlClientPoolService.java | 2 +-
.../control/ProcessBundleDescriptors.java | 2 +-
.../runners/fnexecution/data/GrpcDataService.java | 2 +-
.../jobsubmission/InMemoryJobService.java | 10 +-
.../fnexecution/jobsubmission/JobInvoker.java | 2 +-
.../fnexecution/jobsubmission/JobPreparation.java | 2 +-
.../fnexecution/logging/GrpcLoggingService.java | 2 +-
.../runners/fnexecution/provisioning/JobInfo.java | 2 +-
.../provisioning/StaticGrpcProvisionService.java | 2 +-
.../splittabledofn/SDFFeederViaStateAndTimers.java | 2 +-
.../fnexecution/state/GrpcStateService.java | 2 +-
.../fnexecution/state/StateRequestHandlers.java | 2 +-
.../GrpcContextHeaderAccessorProviderTest.java | 20 +--
.../runners/fnexecution/ServerFactoryTest.java | 8 +-
.../BeamFileSystemArtifactServicesTest.java | 8 +-
.../control/FnApiControlClientPoolServiceTest.java | 4 +-
.../control/FnApiControlClientTest.java | 2 +-
.../fnexecution/data/GrpcDataServiceTest.java | 8 +-
.../jobsubmission/InMemoryJobServiceTest.java | 4 +-
.../logging/GrpcLoggingServiceTest.java | 6 +-
.../StaticGrpcProvisionServiceTest.java | 10 +-
.../fnexecution/state/GrpcStateServiceTest.java | 4 +-
runners/reference/java/build.gradle | 9 +-
.../reference/JobServicePipelineResult.java | 2 +-
.../beam/runners/reference/PortableRunner.java | 4 +-
.../runners/reference/testing/TestJobService.java | 2 +-
.../beam/runners/reference/PortableRunnerTest.java | 4 +-
sdks/java/core/build.gradle | 1 -
sdks/java/fn-execution/build.gradle | 5 -
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 22 ++--
.../beam/sdk/fn/channel/SocketAddressFactory.java | 2 +-
.../data/BeamFnDataBufferingOutboundObserver.java | 4 +-
.../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 4 +-
.../beam/sdk/fn/data/RemoteGrpcPortRead.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortWrite.java | 2 +-
.../sdk/fn/stream/BufferingStreamObserver.java | 4 +-
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 2 +-
.../beam/sdk/fn/stream/DirectStreamObserver.java | 4 +-
.../stream/ForwardingClientResponseObserver.java | 6 +-
.../sdk/fn/stream/OutboundObserverFactory.java | 4 +-
.../sdk/fn/stream/SynchronizedStreamObserver.java | 2 +-
.../fn/test/InProcessManagedChannelFactory.java | 4 +-
.../org/apache/beam/sdk/fn/test/TestStreams.java | 4 +-
.../sdk/fn/windowing/EncodedBoundedWindow.java | 2 +-
.../sdk/fn/channel/ManagedChannelFactoryTest.java | 6 +-
.../sdk/fn/channel/SocketAddressFactoryTest.java | 2 +-
.../BeamFnDataBufferingOutboundObserverTest.java | 2 +-
.../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 2 +-
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 2 +-
.../ForwardingClientResponseObserverTest.java | 6 +-
.../sdk/fn/stream/OutboundObserverFactoryTest.java | 4 +-
.../sdk/fn/windowing/EncodedBoundedWindowTest.java | 2 +-
sdks/java/harness/build.gradle | 5 -
.../beam/fn/harness/BoundedSourceRunner.java | 2 +-
.../java/org/apache/beam/fn/harness/FnHarness.java | 2 +-
.../harness/SplittableProcessElementsRunner.java | 2 +-
.../harness/control/AddHarnessIdInterceptor.java | 8 +-
.../fn/harness/control/BeamFnControlClient.java | 4 +-
.../fn/harness/control/ProcessBundleHandler.java | 4 +-
.../beam/fn/harness/control/RegisterHandler.java | 2 +-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 2 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 12 +-
.../apache/beam/fn/harness/state/BagUserState.java | 2 +-
.../harness/state/BeamFnStateGrpcClientCache.java | 4 +-
.../beam/fn/harness/state/FnApiStateAccessor.java | 2 +-
.../beam/fn/harness/state/MultimapSideInput.java | 2 +-
.../fn/harness/state/StateFetchingIterators.java | 2 +-
.../stream/HarnessStreamObserverFactories.java | 2 +-
.../beam/fn/harness/BoundedSourceRunnerTest.java | 2 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 2 +-
.../org/apache/beam/fn/harness/FnHarnessTest.java | 6 +-
.../harness/control/BeamFnControlClientTest.java | 8 +-
.../harness/control/ProcessBundleHandlerTest.java | 2 +-
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 14 +--
.../data/BeamFnDataInboundObserverTest.java | 2 +-
.../harness/logging/BeamFnLoggingClientTest.java | 16 +--
.../beam/fn/harness/state/BagUserStateTest.java | 2 +-
.../state/BeamFnStateGrpcClientCacheTest.java | 16 +--
.../fn/harness/state/FakeBeamFnStateClient.java | 2 +-
.../fn/harness/state/MultimapSideInputTest.java | 2 +-
.../harness/state/StateFetchingIteratorsTest.java | 2 +-
.../stream/HarnessStreamObserverFactoriesTest.java | 4 +-
138 files changed, 435 insertions(+), 330 deletions(-)
