You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2021/12/01 19:41:00 UTC
[beam] branch master updated (88429b2 -> ed9f620)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 88429b2 Merge pull request #16097 from y1chi/fix_typo
add ed9f620 [BEAM-11936] Fix errorprone UnusedVariable in Runners (#16035)
No new revisions were added by this update.
Summary of changes:
runners/core-construction-java/build.gradle | 1 -
.../runners/core/construction/Environments.java | 3 --
.../beam/runners/core/construction/External.java | 1 -
.../runners/core/construction/ReadTranslation.java | 24 ++++-----
.../construction/renderer/PipelineDotRenderer.java | 1 -
.../core/construction/CombineTranslationTest.java | 4 --
.../core/construction/PTransformMatchersTest.java | 1 +
.../core/construction/PipelineTranslationTest.java | 6 +--
.../core/construction/ReadTranslationTest.java | 7 +--
.../construction/graph/QueryablePipelineTest.java | 30 -----------
runners/core-java/build.gradle | 1 -
.../apache/beam/runners/core/SimpleDoFnRunner.java | 4 --
.../org/apache/beam/runners/core/StateTags.java | 3 --
.../core/serialization/Base64Serializer.java | 1 +
.../runners/core/InMemoryStateInternalsTest.java | 4 --
.../beam/runners/core/ReduceFnRunnerTest.java | 2 -
.../beam/runners/core/SimpleDoFnRunnerTest.java | 1 +
.../SimplePushbackSideInputDoFnRunnerTest.java | 7 +--
.../beam/runners/core/StateInternalsTest.java | 3 --
...SynchronizedProcessingTimeStateMachineTest.java | 3 --
.../core/triggers/TriggerStateMachineTester.java | 17 -------
.../core/triggers/TriggerStateMachinesTest.java | 6 +--
runners/direct-java/build.gradle | 1 -
.../runners/direct/DirectExecutionContext.java | 4 +-
.../beam/runners/direct/EvaluationContext.java | 3 --
.../beam/runners/direct/MultiStepCombine.java | 5 +-
.../beam/runners/direct/WatermarkManager.java | 4 --
.../runners/direct/DirectGraphVisitorTest.java | 15 +++---
...cycleManagerRemovingTransformEvaluatorTest.java | 1 -
.../beam/runners/direct/MultiStepCombineTest.java | 7 ---
.../runners/direct/SideInputContainerTest.java | 31 ++++++------
.../direct/StatefulParDoEvaluatorFactoryTest.java | 2 +
.../runners/direct/WindowEvaluatorFactoryTest.java | 9 ++--
runners/flink/flink_runner.gradle | 1 -
.../FlinkBatchPortablePipelineTranslator.java | 2 -
.../state/FlinkBroadcastStateInternals.java | 6 ---
.../runners/flink/FlinkJobServerDriverTest.java | 4 --
.../beam/runners/flink/FlinkSavepointTest.java | 2 +
.../FlinkStreamingPipelineTranslatorTest.java | 2 +
.../runners/flink/PortableStateExecutionTest.java | 3 ++
.../runners/flink/PortableTimersExecutionTest.java | 2 +
.../wrappers/streaming/DoFnOperatorTest.java | 5 +-
runners/google-cloud-dataflow-java/build.gradle | 1 -
.../examples-streaming/build.gradle | 2 +-
.../examples/build.gradle | 2 +-
.../beam/runners/dataflow/DataflowPipelineJob.java | 4 --
.../dataflow/DataflowPipelineTranslator.java | 44 +++-------------
.../dataflow/BatchStatefulParDoOverridesTest.java | 2 +
.../runners/dataflow/DataflowPipelineJobTest.java | 1 -
.../dataflow/DataflowPipelineTranslatorTest.java | 58 ++++++++++------------
.../beam/runners/dataflow/DataflowRunnerTest.java | 10 ++--
.../google-cloud-dataflow-java/worker/build.gradle | 1 -
.../worker/legacy-worker/build.gradle | 1 -
.../worker/AssignWindowsParDoFnFactory.java | 8 +--
.../dataflow/worker/CounterShortIdCache.java | 4 +-
.../dataflow/worker/DataflowOutputCounter.java | 4 +-
.../dataflow/worker/FnApiWindowMappingFn.java | 5 +-
.../beam/runners/dataflow/worker/ShuffleSink.java | 2 -
.../worker/StreamingModeExecutionContext.java | 1 +
.../dataflow/worker/WindmillStateInternals.java | 6 ---
.../dataflow/worker/WindmillStateReader.java | 7 +--
.../control/DataflowSideInputHandlerFactory.java | 3 --
.../fn/control/ProcessRemoteBundleOperation.java | 2 -
.../graph/CreateExecutableStageNodeFunction.java | 2 -
.../graph/DeduceFlattenLocationsFunction.java | 8 +--
.../worker/graph/RegisterNodeFunction.java | 9 ++--
.../worker/status/SdkWorkerStatusServlet.java | 3 --
.../dataflow/worker/util/MemoryMonitor.java | 1 +
.../worker/util/common/worker/MapTaskExecutor.java | 13 -----
.../worker/BatchModeExecutionContextTest.java | 1 -
.../worker/IntrinsicMapTaskExecutorTest.java | 1 -
.../dataflow/worker/IsmReaderFactoryTest.java | 4 --
.../runners/dataflow/worker/IsmReaderTest.java | 5 --
.../dataflow/worker/IsmSideInputReaderTest.java | 6 +--
.../worker/NoOpSourceOperationExecutorTest.java | 4 --
.../worker/StreamingDataflowWorkerTest.java | 6 ++-
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 16 ++----
.../dataflow/worker/UserParDoFnFactoryTest.java | 2 +
.../dataflow/worker/WindmillStateCacheTest.java | 3 +-
.../dataflow/worker/WindmillStateReaderTest.java | 2 -
.../dataflow/worker/counters/CounterSetTest.java | 4 +-
.../RegisterAndProcessBundleOperationTest.java | 2 -
.../worker/fn/data/BeamFnDataGrpcServiceTest.java | 1 -
.../fn/data/RemoteGrpcPortWriteOperationTest.java | 1 -
...tFetchAndFilterStreamingSideInputNodesTest.java | 11 ++--
.../graph/LengthPrefixUnknownCodersTest.java | 1 -
.../worker/graph/MapTaskToNetworkFunctionTest.java | 2 +-
.../dataflow/worker/status/DebugCaptureTest.java | 3 --
.../worker/testing/RestoreDataflowLoggingMDC.java | 1 -
.../util/DataflowCounterUpdateExtractorTest.java | 6 +--
.../worker/GroupingShuffleEntryIteratorTest.java | 4 --
.../util/common/worker/MapTaskExecutorTest.java | 1 -
.../util/common/worker/ParDoOperationTest.java | 1 -
.../util/common/worker/ReadOperationTest.java | 1 -
.../worker/windmill/GrpcWindmillServerTest.java | 8 ++-
runners/java-fn-execution/build.gradle | 1 -
.../artifact/ArtifactStagingService.java | 5 +-
.../control/BundleCheckpointHandlers.java | 5 +-
.../environment/DockerEnvironmentFactory.java | 8 +--
.../environment/ExternalEnvironmentFactory.java | 5 +-
.../environment/ProcessEnvironmentFactory.java | 6 +--
.../artifact/ArtifactRetrievalServiceTest.java | 8 +--
.../control/ProcessBundleDescriptorsTest.java | 2 +
.../fnexecution/control/RemoteExecutionTest.java | 27 +++++-----
.../fnexecution/control/SdkHarnessClientTest.java | 6 +--
.../environment/DockerEnvironmentFactoryTest.java | 6 ---
.../status/BeamWorkerStatusGrpcServiceTest.java | 3 +-
.../fnexecution/status/WorkerStatusClientTest.java | 3 +-
runners/java-job-service/build.gradle | 1 -
.../jobsubmission/PortablePipelineJarUtils.java | 3 --
.../jobsubmission/InMemoryJobServiceTest.java | 2 -
runners/jet/build.gradle | 1 -
.../runners/jet/processors/BoundedSourceP.java | 8 +--
.../beam/runners/jet/processors/FlattenP.java | 2 +-
.../beam/runners/jet/processors/ImpulseP.java | 2 +
runners/local-java/build.gradle | 1 -
runners/portability/java/build.gradle | 2 +-
.../portability/testing/TestPortableRunner.java | 4 +-
.../portability/testing/TestUniversalRunner.java | 4 --
runners/samza/build.gradle | 1 -
runners/samza/job-server/build.gradle | 1 -
.../apache/beam/runners/samza/SamzaJobInvoker.java | 6 +--
.../beam/runners/samza/SamzaPipelineResult.java | 5 --
.../runners/samza/SamzaPortablePipelineResult.java | 2 +-
.../org/apache/beam/runners/samza/SamzaRunner.java | 2 +-
.../samza/metrics/DoFnRunnerWithMetrics.java | 2 -
.../samza/metrics/SamzaMetricsContainer.java | 1 -
.../runners/samza/runtime/SamzaDoFnRunners.java | 4 --
.../SplittableParDoProcessKeyedElementsOp.java | 2 -
.../translation/FlattenPCollectionsTranslator.java | 6 +--
.../runners/samza/util/PipelineJsonRenderer.java | 3 --
.../runtime/SamzaStoreStateInternalsTest.java | 1 +
.../samza/translation/ConfigGeneratorTest.java | 2 +
.../streaming/DatasetSourceStreaming.java | 4 +-
runners/spark/spark_runner.gradle | 1 -
.../spark/coders/StatelessJavaSerializer.java | 1 +
.../SparkGroupAlsoByWindowViaWindowSet.java | 2 -
.../SparkBatchPortablePipelineTranslator.java | 4 --
.../translation/SparkExecutableStageFunction.java | 20 +++-----
.../SparkStreamingPortablePipelineTranslator.java | 4 --
.../runners/spark/GlobalWatermarkHolderTest.java | 15 +++---
.../GroupNonMergingWindowsFunctionsTest.java | 4 +-
runners/twister2/build.gradle | 1 -
.../Twister2PipelineExecutionEnvironment.java | 2 +-
.../wrappers/Twister2BoundedSource.java | 5 +-
.../Twister2BatchPipelineTranslator.java | 2 -
.../Twister2StreamPipelineTranslator.java | 9 +---
.../functions/AssignWindowsFunction.java | 12 -----
.../translators/functions/ByteToElemFunction.java | 2 -
.../functions/GroupByWindowFunction.java | 9 +---
150 files changed, 218 insertions(+), 572 deletions(-)