beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [beam] branch master updated (50a4baa -> 109f03c)
Date Tue, 10 Jul 2018 21:09:11 GMT
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(-)


Mime
View raw message