beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bhule...@apache.org
Subject [beam] branch master updated (2e9e9a8 -> d378d57)
Date Wed, 03 Mar 2021 03:21:39 GMT
This is an automated email from the ASF dual-hosted git repository.

bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 2e9e9a8  [BEAM-10632] Checkerframework nullness cleanups (#14107)
     add 3d41ad2  never run checkerframework on tests
     add ebe1105  Remove nullness warning suppression
     add c159f45  Remove some false positives
     add d378d57  [BEAM-11436] Never run checkerframework on tests (#14101)

No new revisions were added by this update.

Summary of changes:
 .../groovy/org/apache/beam/gradle/BeamModulePlugin.groovy   | 13 ++++++-------
 .../java/org/apache/beam/examples/WindowedWordCountIT.java  |  3 ---
 .../apache/beam/examples/complete/TrafficMaxLaneFlowIT.java |  3 ---
 .../org/apache/beam/examples/complete/TrafficRoutesIT.java  |  3 ---
 .../runners/core/construction/CoderTranslationTest.java     |  1 -
 .../beam/runners/core/construction/CommonCoderTest.java     |  1 -
 .../core/construction/DefaultArtifactResolverTest.java      |  3 ---
 .../runners/core/construction/ForwardingPTransformTest.java |  3 ---
 .../beam/runners/core/construction/MorePipelineTest.java    |  1 -
 .../core/construction/PCollectionTranslationTest.java       |  3 ---
 .../runners/core/construction/PTransformMatchersTest.java   |  1 -
 .../core/construction/PTransformReplacementsTest.java       |  3 ---
 .../core/construction/PTransformTranslationTest.java        |  3 ---
 .../core/construction/PipelineOptionsTranslationTest.java   |  3 ---
 .../runners/core/construction/PipelineTranslationTest.java  |  1 -
 .../runners/core/construction/ReplacementOutputsTest.java   |  3 ---
 .../runners/core/construction/SchemaTranslationTest.java    |  3 ---
 .../beam/runners/core/construction/SdkComponentsTest.java   |  3 ---
 .../apache/beam/runners/core/construction/TimerTest.java    |  3 ---
 .../runners/core/construction/TriggerTranslationTest.java   |  3 ---
 .../construction/UnboundedReadFromBoundedSourceTest.java    |  3 ---
 .../core/construction/UnsupportedOverrideFactoryTest.java   |  1 -
 .../runners/core/construction/ValidateRunnerXlangTest.java  |  3 ---
 .../core/construction/WindowingStrategyTranslationTest.java |  1 -
 .../core/construction/graph/GreedyPipelineFuserTest.java    |  3 ---
 .../core/construction/graph/GreedyStageFuserTest.java       |  3 ---
 .../core/construction/graph/OutputDeduplicatorTest.java     |  1 -
 .../resources/ClasspathScanningResourcesDetectorTest.java   |  3 ---
 .../core/construction/resources/PipelineResourcesTest.java  |  3 ---
 .../beam/runners/core/InMemoryTimerInternalsTest.java       |  3 ---
 .../beam/runners/core/LateDataDroppingDoFnRunnerTest.java   |  3 ---
 ...utAndTimeBoundedSplittableProcessElementInvokerTest.java |  1 -
 .../java/org/apache/beam/runners/core/ReduceFnTester.java   |  1 -
 .../org/apache/beam/runners/core/SideInputHandlerTest.java  |  3 ---
 .../org/apache/beam/runners/core/SimpleDoFnRunnerTest.java  |  1 -
 .../runners/core/SimplePushbackSideInputDoFnRunnerTest.java |  1 -
 .../beam/runners/core/SplittableParDoProcessFnTest.java     |  3 ---
 .../org/apache/beam/runners/core/StateInternalsTest.java    |  3 ---
 .../apache/beam/runners/core/StatefulDoFnRunnerTest.java    |  1 -
 .../java/org/apache/beam/runners/core/WindowMatchers.java   |  3 ---
 .../runners/core/metrics/ExecutionStateSamplerTest.java     |  3 ---
 .../runners/core/metrics/ExecutionStateTrackerTest.java     |  3 ---
 .../beam/runners/core/metrics/LabeledMetricsTest.java       |  3 ---
 .../beam/runners/core/metrics/MetricUpdateMatchers.java     |  3 ---
 .../beam/runners/core/metrics/MetricsContainerImplTest.java |  3 ---
 .../runners/core/metrics/MetricsContainerStepMapTest.java   |  3 ---
 .../apache/beam/runners/core/metrics/MetricsPusherTest.java |  3 ---
 .../runners/core/metrics/MonitoringInfoMetricNameTest.java  |  3 ---
 .../beam/runners/core/metrics/MonitoringInfoTestUtil.java   |  1 -
 .../beam/runners/core/metrics/SimpleExecutionStateTest.java |  3 ---
 .../core/metrics/SimpleMonitoringInfoBuilderTest.java       |  3 ---
 .../beam/runners/core/metrics/SimpleStateRegistryTest.java  |  3 ---
 .../apache/beam/runners/core/metrics/TestMetricsSink.java   |  3 ---
 .../runners/core/triggers/AfterAllStateMachineTest.java     |  3 ---
 .../runners/core/triggers/AfterEachStateMachineTest.java    |  3 ---
 .../runners/core/triggers/AfterFirstStateMachineTest.java   |  3 ---
 .../runners/core/triggers/AfterPaneStateMachineTest.java    |  3 ---
 .../core/triggers/AfterWatermarkStateMachineTest.java       |  3 ---
 .../core/triggers/DefaultTriggerStateMachineTest.java       |  3 ---
 .../beam/runners/core/triggers/NeverStateMachineTest.java   |  3 ---
 .../runners/core/triggers/OrFinallyStateMachineTest.java    |  3 ---
 .../runners/core/triggers/RepeatedlyStateMachineTest.java   |  3 ---
 .../beam/runners/core/triggers/TriggerStateMachineTest.java |  3 ---
 .../runners/core/triggers/TriggerStateMachineTester.java    |  3 ---
 .../runners/direct/BoundedReadEvaluatorFactoryTest.java     |  1 -
 .../beam/runners/direct/CloningBundleFactoryTest.java       |  3 ---
 .../direct/CopyOnAccessInMemoryStateInternalsTest.java      |  3 ---
 .../org/apache/beam/runners/direct/DirectMetricsTest.java   |  3 ---
 .../beam/runners/direct/DirectRunnerApiSurfaceTest.java     |  3 ---
 .../org/apache/beam/runners/direct/DirectRunnerTest.java    |  1 -
 .../beam/runners/direct/DirectTimerInternalsTest.java       |  1 -
 .../beam/runners/direct/DirectTransformExecutorTest.java    |  1 -
 .../DoFnLifecycleManagerRemovingTransformEvaluatorTest.java |  3 ---
 .../beam/runners/direct/DoFnLifecycleManagersTest.java      |  3 ---
 .../apache/beam/runners/direct/EvaluationContextTest.java   |  1 -
 .../beam/runners/direct/FlattenEvaluatorFactoryTest.java    |  2 +-
 .../beam/runners/direct/GroupByKeyEvaluatorFactoryTest.java |  3 ---
 .../runners/direct/GroupByKeyOnlyEvaluatorFactoryTest.java  |  3 ---
 .../direct/ImmutabilityCheckingBundleFactoryTest.java       |  3 ---
 .../runners/direct/ImmutabilityEnforcementFactoryTest.java  |  3 ---
 .../beam/runners/direct/ImmutableListBundleFactoryTest.java |  3 ---
 .../beam/runners/direct/KeyedPValueTrackingVisitorTest.java |  3 ---
 .../org/apache/beam/runners/direct/ParDoEvaluatorTest.java  |  2 +-
 .../apache/beam/runners/direct/SideInputContainerTest.java  |  3 ---
 .../runners/direct/StatefulParDoEvaluatorFactoryTest.java   |  1 -
 .../apache/beam/runners/direct/StepTransformResultTest.java |  3 ---
 .../beam/runners/direct/TestStreamEvaluatorFactoryTest.java |  3 +--
 .../beam/runners/direct/TransformExecutorServicesTest.java  |  3 ---
 .../runners/direct/UnboundedReadEvaluatorFactoryTest.java   |  3 +--
 .../beam/runners/direct/ViewEvaluatorFactoryTest.java       |  3 ---
 .../beam/runners/direct/WatermarkCallbackExecutorTest.java  |  3 ---
 .../apache/beam/runners/direct/WatermarkManagerTest.java    |  1 -
 .../beam/runners/direct/WindowEvaluatorFactoryTest.java     |  3 ---
 .../runners/extensions/metrics/MetricsGraphiteSinkTest.java |  3 ---
 .../runners/extensions/metrics/MetricsHttpSinkTest.java     |  3 ---
 .../beam/runners/extensions/metrics/NetworkMockServer.java  |  3 ---
 .../apache/beam/runners/flink/FlinkRunnerTestCompat.java    |  3 ---
 .../flink/translation/types/CoderTypeSerializerTest.java    |  1 -
 .../beam/runners/flink/FlinkExecutionEnvironmentsTest.java  |  3 ---
 .../flink/FlinkPipelineExecutionEnvironmentTest.java        |  1 -
 .../apache/beam/runners/flink/FlinkPipelineOptionsTest.java |  3 ---
 .../beam/runners/flink/FlinkRequiresStableInputTest.java    |  3 ---
 .../java/org/apache/beam/runners/flink/FlinkRunnerTest.java |  3 ---
 .../org/apache/beam/runners/flink/FlinkSavepointTest.java   |  1 -
 .../flink/FlinkStreamingTransformTranslatorsTest.java       |  1 -
 .../org/apache/beam/runners/flink/FlinkSubmissionTest.java  |  1 -
 .../beam/runners/flink/FlinkTransformOverridesTest.java     |  3 ---
 .../apache/beam/runners/flink/PortableExecutionTest.java    |  3 ---
 .../beam/runners/flink/PortableStateExecutionTest.java      |  3 ---
 .../beam/runners/flink/PortableTimersExecutionTest.java     |  3 ---
 .../apache/beam/runners/flink/ReadSourcePortableTest.java   |  3 ---
 .../apache/beam/runners/flink/ReadSourceStreamingTest.java  |  3 ---
 .../java/org/apache/beam/runners/flink/ReadSourceTest.java  |  3 ---
 .../beam/runners/flink/batch/NonMergingGroupByKeyTest.java  |  3 ---
 .../org/apache/beam/runners/flink/batch/ReshuffleTest.java  |  3 ---
 .../runners/flink/metrics/FlinkMetricContainerTest.java     |  3 ---
 .../flink/streaming/FlinkBroadcastStateInternalsTest.java   |  3 ---
 .../runners/flink/streaming/FlinkStateInternalsTest.java    |  1 -
 .../beam/runners/flink/streaming/GroupByNullKeyTest.java    |  3 ---
 .../runners/flink/streaming/GroupByWithNullValuesTest.java  |  3 ---
 .../runners/flink/streaming/TopWikipediaSessionsTest.java   |  3 ---
 .../flink/translation/functions/FlinkDoFnFunctionTest.java  |  1 -
 .../functions/FlinkExecutableStageFunctionTest.java         |  1 -
 .../functions/FlinkStatefulDoFnFunctionTest.java            |  1 -
 .../translation/wrappers/streaming/DoFnOperatorTest.java    |  2 +-
 .../wrappers/streaming/ExecutableStageDoFnOperatorTest.java |  1 -
 .../wrappers/streaming/StreamRecordStripper.java            |  3 ---
 .../wrappers/streaming/WindowDoFnOperatorTest.java          |  1 -
 .../wrappers/streaming/io/TestCountingSource.java           |  3 ---
 .../wrappers/streaming/io/UnboundedSourceWrapperTest.java   |  1 -
 .../runners/dataflow/BatchStatefulParDoOverridesTest.java   |  3 ---
 .../apache/beam/runners/dataflow/DataflowMetricsTest.java   |  1 -
 .../runners/dataflow/DataflowPTransformMatchersTest.java    |  3 ---
 .../beam/runners/dataflow/DataflowPipelineJobTest.java      |  3 ---
 .../runners/dataflow/DataflowPipelineTranslatorTest.java    |  1 -
 .../beam/runners/dataflow/DataflowRunnerInfoTest.java       |  3 ---
 .../apache/beam/runners/dataflow/DataflowRunnerTest.java    |  3 ---
 .../beam/runners/dataflow/RecordingPipelineVisitor.java     |  3 ---
 .../beam/runners/dataflow/TestDataflowRunnerTest.java       |  3 ---
 .../dataflow/options/DataflowPipelineOptionsTest.java       |  3 ---
 .../dataflow/options/DataflowWorkerLoggingOptionsTest.java  |  3 ---
 .../runners/dataflow/transforms/DataflowGroupByKeyTest.java |  3 ---
 .../beam/runners/dataflow/transforms/DataflowViewTest.java  |  3 ---
 .../apache/beam/runners/dataflow/util/CloudObjectsTest.java |  1 -
 .../beam/runners/dataflow/util/MonitoringUtilTest.java      |  3 ---
 .../apache/beam/runners/dataflow/util/PackageUtilTest.java  |  3 ---
 .../org/apache/beam/runners/dataflow/util/StructsTest.java  |  3 ---
 .../org/apache/beam/runners/dataflow/util/TimeUtilTest.java |  3 ---
 .../beam/runners/dataflow/harness/test/TestExecutors.java   |  3 ---
 .../runners/dataflow/harness/test/TestExecutorsTest.java    |  1 -
 .../beam/runners/dataflow/harness/test/TestStreamsTest.java |  3 ---
 .../dataflow/worker/ApplianceShuffleCountersTest.java       |  3 ---
 .../runners/dataflow/worker/AvroByteReaderFactoryTest.java  |  1 -
 .../beam/runners/dataflow/worker/AvroByteReaderTest.java    |  1 -
 .../runners/dataflow/worker/BatchDataflowWorkerTest.java    |  3 ---
 .../dataflow/worker/BatchModeExecutionContextTest.java      |  3 ---
 .../runners/dataflow/worker/ConcatReaderFactoryTest.java    |  3 ---
 .../beam/runners/dataflow/worker/ConcatReaderTest.java      |  1 -
 .../worker/CreateIsmShardKeyAndSortKeyDoFnFactoryTest.java  |  3 ---
 .../dataflow/worker/DataflowBatchWorkerHarnessTest.java     |  3 ---
 .../worker/DataflowElementExecutionTrackerTest.java         |  3 ---
 .../dataflow/worker/DataflowExecutionStateTrackerTest.java  |  3 ---
 .../dataflow/worker/DataflowOperationContextTest.java       |  3 ---
 .../dataflow/worker/DataflowWorkProgressUpdaterTest.java    |  3 ---
 .../runners/dataflow/worker/DataflowWorkUnitClientTest.java |  3 ---
 .../dataflow/worker/DataflowWorkerHarnessHelperTest.java    |  3 ---
 .../runners/dataflow/worker/DefaultParDoFnFactoryTest.java  |  1 -
 .../beam/runners/dataflow/worker/DeltaCounterCellTest.java  |  3 ---
 .../runners/dataflow/worker/DoFnInstanceManagersTest.java   |  3 ---
 .../beam/runners/dataflow/worker/FakeWindmillServer.java    |  3 ---
 .../runners/dataflow/worker/FnApiWindowMappingFnTest.java   |  1 -
 .../runners/dataflow/worker/GroupingShuffleReaderTest.java  |  1 -
 .../beam/runners/dataflow/worker/HotKeyLoggerTest.java      |  3 ---
 .../runners/dataflow/worker/InMemoryReaderFactoryTest.java  |  3 ---
 .../worker/IntrinsicMapTaskExecutorFactoryTest.java         |  1 -
 .../dataflow/worker/IntrinsicMapTaskExecutorTest.java       |  3 ---
 .../beam/runners/dataflow/worker/IsmReaderFactoryTest.java  |  3 ---
 .../apache/beam/runners/dataflow/worker/IsmReaderTest.java  |  1 -
 .../runners/dataflow/worker/IsmSideInputReaderTest.java     |  2 +-
 .../worker/LazilyInitializedSideInputReaderTest.java        |  1 -
 .../beam/runners/dataflow/worker/LogRecordMatcher.java      |  3 ---
 .../beam/runners/dataflow/worker/LogRecordMatcherTest.java  |  1 -
 .../dataflow/worker/NoOpSourceOperationExecutorTest.java    |  3 ---
 .../dataflow/worker/PairWithConstantKeyDoFnFactoryTest.java |  3 ---
 .../dataflow/worker/PartialGroupByKeyParDoFnsTest.java      |  1 -
 .../dataflow/worker/PartitioningShuffleReaderTest.java      |  3 ---
 .../beam/runners/dataflow/worker/PubsubReaderTest.java      |  3 ---
 .../apache/beam/runners/dataflow/worker/PubsubSinkTest.java |  3 ---
 .../beam/runners/dataflow/worker/ReaderCacheTest.java       |  3 ---
 .../beam/runners/dataflow/worker/ReaderFactoryTest.java     |  1 -
 .../beam/runners/dataflow/worker/ReaderTestUtils.java       |  3 ---
 .../worker/ReifyTimestampAndWindowsParDoFnFactoryTest.java  |  3 ---
 .../runners/dataflow/worker/SdkHarnessRegistryTest.java     |  3 ---
 .../runners/dataflow/worker/ShuffleReaderFactoryTest.java   |  1 -
 .../beam/runners/dataflow/worker/ShuffleSinkTest.java       |  3 ---
 .../beam/runners/dataflow/worker/SimpleParDoFnTest.java     |  3 ---
 .../dataflow/worker/SourceOperationExecutorFactoryTest.java |  3 ---
 .../beam/runners/dataflow/worker/StateFetcherTest.java      |  3 ---
 .../dataflow/worker/StreamingDataflowWorkerTest.java        |  3 ---
 .../dataflow/worker/StreamingGroupAlsoByWindowFnsTest.java  |  3 ---
 .../StreamingGroupAlsoByWindowsReshuffleDoFnTest.java       |  3 ---
 .../StreamingKeyedWorkItemSideInputDoFnRunnerTest.java      |  3 ---
 .../dataflow/worker/StreamingModeExecutionContextTest.java  |  3 ---
 .../StreamingPCollectionViewWriterDoFnFactoryTest.java      |  1 -
 .../dataflow/worker/StreamingSideInputDoFnRunnerTest.java   |  3 ---
 .../dataflow/worker/StreamingSideInputFetcherTest.java      |  3 ---
 .../beam/runners/dataflow/worker/TestOperationContext.java  |  3 ---
 .../dataflow/worker/TestShuffleReadCounterFactory.java      |  3 ---
 .../beam/runners/dataflow/worker/TestShuffleReaderTest.java |  3 ---
 .../worker/ToIsmRecordForMultimapDoFnFactoryTest.java       |  3 ---
 .../runners/dataflow/worker/UngroupedShuffleReaderTest.java |  3 ---
 .../runners/dataflow/worker/UserParDoFnFactoryTest.java     |  3 ---
 .../beam/runners/dataflow/worker/ValuesDoFnFactoryTest.java |  3 ---
 .../runners/dataflow/worker/WindmillKeyedWorkItemTest.java  |  3 ---
 .../runners/dataflow/worker/WindmillStateCacheTest.java     |  3 ---
 .../runners/dataflow/worker/WindmillStateInternalsTest.java |  1 -
 .../runners/dataflow/worker/WindmillStateReaderTest.java    |  1 -
 .../runners/dataflow/worker/WindmillStateTestUtils.java     |  3 ---
 .../beam/runners/dataflow/worker/WindmillTimeUtilsTest.java |  3 ---
 .../runners/dataflow/worker/WorkItemStatusClientTest.java   |  3 ---
 .../runners/dataflow/worker/WorkerCustomSourcesTest.java    |  3 ---
 .../beam/runners/dataflow/worker/apiary/ApiaryTest.java     |  2 +-
 .../counters/DistributionCounterUpdateAggregatorTest.java   |  3 ---
 .../worker/counters/MeanCounterUpdateAggregatorTest.java    |  3 ---
 .../worker/counters/SumCounterUpdateAggregatorTest.java     |  3 ---
 .../dataflow/worker/fn/BeamFnControlServiceTest.java        |  3 ---
 .../worker/fn/control/BeamFnMapTaskExecutorTest.java        |  1 -
 .../fn/control/DataflowSideInputHandlerFactoryTest.java     |  1 -
 ...ntCountMonitoringInfoToCounterUpdateTransformerTest.java |  3 ---
 ...ionTimeMonitoringInfoToCounterUpdateTransformerTest.java |  3 ---
 .../FnApiMonitoringInfoToCounterUpdateTransformerTest.java  |  3 ---
 ...teCountMonitoringInfoToCounterUpdateTransformerTest.java |  3 ---
 .../fn/control/RegisterAndProcessBundleOperationTest.java   |  1 -
 .../control/SingularProcessBundleProgressTrackerTest.java   |  1 -
 ...ibutionMonitoringInfoToCounterUpdateTransformerTest.java |  3 ---
 .../UserMonitoringInfoToCounterUpdateTransformerTest.java   |  3 ---
 .../dataflow/worker/fn/data/BeamFnDataGrpcServiceTest.java  |  1 -
 .../worker/fn/data/RemoteGrpcPortReadOperationTest.java     |  3 ---
 .../worker/fn/data/RemoteGrpcPortWriteOperationTest.java    |  3 ---
 .../worker/fn/logging/BeamFnLoggingServiceTest.java         |  3 ---
 .../worker/fn/stream/ServerStreamObserverFactoryTest.java   |  3 ---
 .../worker/graph/CloneAmbiguousFlattensFunctionTest.java    |  3 ---
 .../worker/graph/CreateRegisterFnOperationFunctionTest.java |  3 ---
 .../worker/graph/LengthPrefixUnknownCodersTest.java         |  3 ---
 .../beam/runners/dataflow/worker/graph/NetworksTest.java    |  3 ---
 .../beam/runners/dataflow/worker/graph/NodesTest.java       |  1 -
 .../worker/graph/ReplacePgbkWithPrecombineFunctionTest.java |  3 ---
 .../worker/logging/DataflowWorkerLoggingHandlerTest.java    |  3 ---
 .../logging/DataflowWorkerLoggingInitializerTest.java       |  3 ---
 .../logging/JulHandlerPrintStreamAdapterFactoryTest.java    |  3 ---
 .../dataflow/worker/profiler/ScopedProfilerTest.java        |  3 ---
 .../runners/dataflow/worker/status/DebugCaptureTest.java    |  3 ---
 .../dataflow/worker/status/WorkerStatusPagesTest.java       |  3 ---
 .../dataflow/worker/testing/GenericJsonMatcherTest.java     |  3 ---
 .../dataflow/worker/testing/RestoreDataflowLoggingMDC.java  |  3 ---
 .../runners/dataflow/worker/testing/TestCountingSource.java |  3 ---
 .../dataflow/worker/util/CounterHamcrestMatchers.java       |  3 ---
 .../dataflow/worker/util/GroupAlsoByWindowProperties.java   |  3 ---
 .../runners/dataflow/worker/util/MemoryMonitorTest.java     |  3 ---
 .../worker/util/common/TaggedReiteratorListTest.java        |  2 +-
 .../util/common/worker/BatchingShuffleEntryReaderTest.java  |  3 ---
 .../worker/util/common/worker/ExecutorTestUtils.java        |  1 -
 .../common/worker/GroupingShuffleEntryIteratorTest.java     |  1 -
 .../worker/util/common/worker/GroupingTablesTest.java       |  3 ---
 .../worker/util/common/worker/MapTaskExecutorTest.java      |  3 ---
 .../util/common/worker/OutputObjectAndByteCounterTest.java  |  3 ---
 .../worker/util/common/worker/ReadOperationTest.java        |  3 ---
 .../worker/util/common/worker/ShuffleEntryTest.java         |  3 ---
 .../dataflow/worker/util/common/worker/StubbedExecutor.java |  3 ---
 .../worker/util/common/worker/TestOutputReceiver.java       |  3 ---
 .../worker/util/common/worker/WorkProgressUpdaterTest.java  |  3 ---
 .../dataflow/worker/windmill/GrpcWindmillServerTest.java    |  1 -
 .../apache/beam/runners/fnexecution/EmbeddedSdkHarness.java |  3 ---
 .../fnexecution/artifact/ArtifactRetrievalServiceTest.java  |  3 ---
 .../fnexecution/artifact/ArtifactStagingServiceTest.java    |  3 ---
 .../fnexecution/control/DefaultJobBundleFactoryTest.java    |  3 ---
 .../control/FnApiControlClientPoolServiceTest.java          |  3 ---
 .../runners/fnexecution/control/FnApiControlClientTest.java |  3 ---
 .../fnexecution/control/ProcessBundleDescriptorsTest.java   |  3 ---
 .../runners/fnexecution/control/RemoteExecutionTest.java    |  5 ++---
 .../runners/fnexecution/control/SdkHarnessClientTest.java   |  1 -
 .../SingleEnvironmentInstanceJobBundleFactoryTest.java      |  3 ---
 .../environment/DockerEnvironmentFactoryTest.java           |  3 ---
 .../environment/ProcessEnvironmentFactoryTest.java          |  3 ---
 .../runners/fnexecution/environment/ProcessManagerTest.java |  3 ---
 .../runners/fnexecution/state/GrpcStateServiceTest.java     |  1 -
 .../fnexecution/status/BeamWorkerStatusGrpcServiceTest.java |  3 ---
 .../runners/fnexecution/status/WorkerStatusClientTest.java  |  3 ---
 .../translation/BatchSideInputHandlerFactoryTest.java       |  3 ---
 .../beam/runners/fnexecution/wire/ByteStringCoderTest.java  |  3 ---
 .../fnexecution/wire/LengthPrefixUnknownCodersTest.java     |  3 ---
 .../beam/runners/jobsubmission/InMemoryJobServiceTest.java  |  3 ---
 .../beam/runners/jobsubmission/JobInvocationTest.java       |  3 ---
 .../jobsubmission/PortablePipelineJarCreatorTest.java       |  3 ---
 .../java/org/apache/beam/runners/jet/TestJetRunner.java     |  1 -
 .../test/java/org/apache/beam/runners/jet/TestStreamP.java  |  1 -
 .../beam/runners/samza/adapter/BoundedSourceSystemTest.java |  3 ---
 .../beam/runners/samza/adapter/TestSourceHelpers.java       |  3 ---
 .../beam/runners/samza/adapter/TestUnboundedSource.java     |  3 ---
 .../runners/samza/adapter/UnboundedSourceSystemTest.java    |  3 ---
 .../beam/runners/samza/runtime/BundleManagerTest.java       |  2 --
 .../runners/samza/runtime/SamzaStoreStateInternalsTest.java |  1 -
 .../samza/runtime/SamzaTimerInternalsFactoryTest.java       |  1 -
 .../beam/runners/samza/translation/ConfigGeneratorTest.java |  3 ---
 .../runners/samza/translation/SamzaImpulseSystemTest.java   |  1 -
 .../apache/beam/runners/samza/util/TestHashIdGenerator.java |  3 ---
 .../test/java/org/apache/beam/runners/spark/CacheTest.java  |  1 -
 .../beam/runners/spark/GlobalWatermarkHolderTest.java       |  3 ---
 .../apache/beam/runners/spark/ProvidedSparkContextTest.java |  3 ---
 .../apache/beam/runners/spark/SparkPipelineStateTest.java   |  3 ---
 .../spark/aggregators/metrics/sink/InMemoryMetrics.java     |  3 ---
 .../org/apache/beam/runners/spark/io/AvroPipelineTest.java  |  3 ---
 .../org/apache/beam/runners/spark/io/NumShardsTest.java     |  3 ---
 .../beam/runners/spark/io/ReaderToIteratorAdapterTest.java  |  3 ---
 .../StructuredStreamingPipelineStateTest.java               |  3 ---
 .../aggregators/metrics/sink/InMemoryMetrics.java           |  3 ---
 .../aggregators/metrics/sink/SparkMetricsSinkTest.java      |  3 ---
 .../structuredstreaming/translation/batch/CombineTest.java  |  3 ---
 .../translation/batch/ComplexSourceTest.java                |  3 ---
 .../structuredstreaming/translation/batch/FlattenTest.java  |  3 ---
 .../translation/batch/GroupByKeyTest.java                   |  3 ---
 .../structuredstreaming/translation/batch/ParDoTest.java    |  3 ---
 .../translation/batch/SimpleSourceTest.java                 |  3 ---
 .../translation/batch/WindowAssignTest.java                 |  3 ---
 .../translation/streaming/SimpleSourceTest.java             |  3 ---
 .../structuredstreaming/utils/SerializationDebugger.java    |  3 ---
 .../spark/translation/SparkExecutableStageFunctionTest.java |  1 -
 .../streaming/ResumeFromCheckpointStreamingTest.java        |  1 -
 .../translation/streaming/TrackStreamingSourcesTest.java    |  1 -
 .../translation/streaming/utils/EmbeddedKafkaCluster.java   |  3 ---
 sdks/java/core/build.gradle                                 |  1 -
 .../src/test/java/org/apache/beam/sdk/PipelineTest.java     |  1 -
 .../core/src/test/java/org/apache/beam/sdk/TestUtils.java   |  3 ---
 .../test/java/org/apache/beam/sdk/coders/AvroCoderTest.java |  3 ---
 .../java/org/apache/beam/sdk/coders/AvroCoderTestPojo.java  |  3 ---
 .../org/apache/beam/sdk/coders/BigDecimalCoderTest.java     |  3 ---
 .../apache/beam/sdk/coders/BigEndianIntegerCoderTest.java   |  3 ---
 .../org/apache/beam/sdk/coders/BigEndianLongCoderTest.java  |  3 ---
 .../org/apache/beam/sdk/coders/BigIntegerCoderTest.java     |  3 ---
 .../java/org/apache/beam/sdk/coders/BitSetCoderTest.java    |  3 ---
 .../java/org/apache/beam/sdk/coders/ByteArrayCoderTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/coders/ByteCoderTest.java |  3 ---
 .../java/org/apache/beam/sdk/coders/CoderRegistryTest.java  |  3 ---
 .../src/test/java/org/apache/beam/sdk/coders/CoderTest.java |  3 ---
 .../org/apache/beam/sdk/coders/CollectionCoderTest.java     |  3 ---
 .../java/org/apache/beam/sdk/coders/DequeCoderTest.java     |  3 ---
 .../java/org/apache/beam/sdk/coders/DoubleCoderTest.java    |  3 ---
 .../java/org/apache/beam/sdk/coders/DurationCoderTest.java  |  3 ---
 .../java/org/apache/beam/sdk/coders/FloatCoderTest.java     |  3 ---
 .../java/org/apache/beam/sdk/coders/InstantCoderTest.java   |  3 ---
 .../java/org/apache/beam/sdk/coders/IterableCoderTest.java  |  3 ---
 .../test/java/org/apache/beam/sdk/coders/KvCoderTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/coders/ListCoderTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/coders/MapCoderTest.java  |  3 ---
 .../java/org/apache/beam/sdk/coders/NullableCoderTest.java  |  3 ---
 .../apache/beam/sdk/coders/PCollectionCustomCoderTest.java  |  3 ---
 .../org/apache/beam/sdk/coders/PrintBase64Encodings.java    |  3 ---
 .../org/apache/beam/sdk/coders/SerializableCoderTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/coders/SetCoderTest.java  |  3 ---
 .../org/apache/beam/sdk/coders/StringUtf8CoderTest.java     |  3 ---
 .../org/apache/beam/sdk/coders/StructuredCoderTest.java     |  3 ---
 .../org/apache/beam/sdk/coders/TextualIntegerCoderTest.java |  3 ---
 .../java/org/apache/beam/sdk/coders/VarIntCoderTest.java    |  3 ---
 .../java/org/apache/beam/sdk/coders/VarLongCoderTest.java   |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/AvroIOTest.java    |  1 -
 .../test/java/org/apache/beam/sdk/io/AvroSourceTest.java    |  3 ---
 .../beam/sdk/io/BoundedReadFromUnboundedSourceTest.java     |  3 ---
 .../org/apache/beam/sdk/io/ClassLoaderFileSystemTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/CompressedSourceTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/CountingSourceTest.java     |  3 ---
 .../org/apache/beam/sdk/io/DefaultFilenamePolicyTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java |  1 -
 .../java/org/apache/beam/sdk/io/FileBasedSourceTest.java    |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/FileIOTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/FileSystemsTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/LocalFileSystemTest.java    |  3 ---
 .../java/org/apache/beam/sdk/io/LocalResourceIdTest.java    |  3 ---
 .../java/org/apache/beam/sdk/io/OffsetBasedSourceTest.java  |  3 ---
 .../core/src/test/java/org/apache/beam/sdk/io/ReadTest.java |  1 -
 .../src/test/java/org/apache/beam/sdk/io/SimpleSink.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/TFRecordIOTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/TextIOReadTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/TextIOWriteTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/io/TextSourceTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/WriteFilesTest.java    |  3 ---
 .../beam/sdk/io/range/ByteKeyRangeInterpolateKeyTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/range/ByteKeyRangeTest.java |  3 ---
 .../org/apache/beam/sdk/metrics/MetricResultsMatchers.java  |  3 ---
 .../org/apache/beam/sdk/metrics/MetricsEnvironmentTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/metrics/MetricsTest.java  |  3 ---
 .../apache/beam/sdk/options/PipelineOptionsFactoryTest.java |  1 -
 .../beam/sdk/options/PipelineOptionsValidatorTest.java      |  3 ---
 .../apache/beam/sdk/options/ProxyInvocationHandlerTest.java |  3 ---
 .../beam/sdk/options/RemoteEnvironmentOptionsTest.java      |  3 ---
 .../org/apache/beam/sdk/options/SdkHarnessOptionsTest.java  |  3 ---
 .../org/apache/beam/sdk/runners/TransformHierarchyTest.java |  3 ---
 .../java/org/apache/beam/sdk/runners/TransformTreeTest.java |  3 ---
 .../org/apache/beam/sdk/schemas/AutoValueSchemaTest.java    |  3 ---
 .../java/org/apache/beam/sdk/schemas/AvroSchemaTest.java    |  3 ---
 .../apache/beam/sdk/schemas/FieldAccessDescriptorTest.java  |  3 ---
 .../org/apache/beam/sdk/schemas/JavaBeanSchemaTest.java     |  3 ---
 .../org/apache/beam/sdk/schemas/JavaFieldSchemaTest.java    |  3 ---
 .../java/org/apache/beam/sdk/schemas/SchemaCoderTest.java   |  1 -
 .../java/org/apache/beam/sdk/schemas/SchemaOptionsTest.java |  3 ---
 .../org/apache/beam/sdk/schemas/SchemaRegistryTest.java     |  1 -
 .../test/java/org/apache/beam/sdk/schemas/SchemaTest.java   |  3 ---
 .../beam/sdk/schemas/logicaltypes/LogicalTypesTest.java     |  3 ---
 .../apache/beam/sdk/schemas/transforms/AddFieldsTest.java   |  3 ---
 .../beam/sdk/schemas/transforms/CastValidatorTest.java      |  3 ---
 .../org/apache/beam/sdk/schemas/transforms/CoGroupTest.java |  1 -
 .../org/apache/beam/sdk/schemas/transforms/ConvertTest.java |  3 ---
 .../org/apache/beam/sdk/schemas/transforms/FilterTest.java  |  3 ---
 .../org/apache/beam/sdk/schemas/transforms/GroupTest.java   |  1 -
 .../org/apache/beam/sdk/schemas/transforms/JoinTest.java    |  3 ---
 .../org/apache/beam/sdk/schemas/transforms/SelectTest.java  |  3 ---
 .../org/apache/beam/sdk/schemas/utils/AvroGenerators.java   |  3 ---
 .../org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java    |  1 -
 .../apache/beam/sdk/schemas/utils/JavaBeanUtilsTest.java    |  1 -
 .../org/apache/beam/sdk/schemas/utils/POJOUtilsTest.java    |  1 -
 .../org/apache/beam/sdk/schemas/utils/SchemaTestUtils.java  |  3 ---
 .../apache/beam/sdk/schemas/utils/SelectHelpersTest.java    |  3 ---
 .../org/apache/beam/sdk/schemas/utils/TestJavaBeans.java    |  3 ---
 .../java/org/apache/beam/sdk/schemas/utils/TestPOJOs.java   |  3 ---
 .../java/org/apache/beam/sdk/state/StateContextsTest.java   |  3 ---
 .../org/apache/beam/sdk/testing/CoderPropertiesTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/testing/ExpectedLogs.java |  3 ---
 .../java/org/apache/beam/sdk/testing/ExpectedLogsTest.java  |  3 ---
 .../apache/beam/sdk/testing/FileChecksumMatcherTest.java    |  3 ---
 .../apache/beam/sdk/testing/InterceptingUrlClassLoader.java |  3 ---
 .../test/java/org/apache/beam/sdk/testing/PAssertTest.java  |  1 -
 .../apache/beam/sdk/testing/RestoreSystemProperties.java    |  3 ---
 .../beam/sdk/testing/RestoreSystemPropertiesTest.java       |  3 ---
 .../apache/beam/sdk/testing/SerializableMatchersTest.java   |  3 ---
 .../org/apache/beam/sdk/testing/SourceTestUtilsTest.java    |  3 ---
 .../java/org/apache/beam/sdk/testing/TestStreamTest.java    |  3 ---
 .../java/org/apache/beam/sdk/testing/ThreadLeakTracker.java |  3 ---
 .../apache/beam/sdk/transforms/ApproximateUniqueTest.java   |  3 ---
 .../java/org/apache/beam/sdk/transforms/CombineFnsTest.java |  3 ---
 .../java/org/apache/beam/sdk/transforms/CombineTest.java    |  3 ---
 .../java/org/apache/beam/sdk/transforms/CreateTest.java     |  1 -
 .../java/org/apache/beam/sdk/transforms/DistinctTest.java   |  3 ---
 .../java/org/apache/beam/sdk/transforms/FilterTest.java     |  3 ---
 .../org/apache/beam/sdk/transforms/FlatMapElementsTest.java |  3 ---
 .../java/org/apache/beam/sdk/transforms/FlattenTest.java    |  3 ---
 .../java/org/apache/beam/sdk/transforms/JsonToRowTest.java  |  3 ---
 .../java/org/apache/beam/sdk/transforms/KvSwapTest.java     |  1 -
 .../java/org/apache/beam/sdk/transforms/LatestFnTest.java   |  3 ---
 .../java/org/apache/beam/sdk/transforms/LatestTest.java     |  3 ---
 .../org/apache/beam/sdk/transforms/MapElementsTest.java     |  3 ---
 .../java/org/apache/beam/sdk/transforms/PTransformTest.java |  3 ---
 .../org/apache/beam/sdk/transforms/ParDoLifecycleTest.java  |  1 -
 .../org/apache/beam/sdk/transforms/ParDoSchemaTest.java     |  3 ---
 .../test/java/org/apache/beam/sdk/transforms/ParDoTest.java |  1 -
 .../java/org/apache/beam/sdk/transforms/PartitionTest.java  |  3 ---
 .../java/org/apache/beam/sdk/transforms/SampleTest.java     |  3 ---
 .../test/java/org/apache/beam/sdk/transforms/SetsTest.java  |  3 ---
 .../org/apache/beam/sdk/transforms/SimpleStatsFnsTest.java  |  3 ---
 .../org/apache/beam/sdk/transforms/SplittableDoFnTest.java  |  1 -
 .../test/java/org/apache/beam/sdk/transforms/ViewTest.java  |  3 ---
 .../test/java/org/apache/beam/sdk/transforms/WaitTest.java  |  3 ---
 .../test/java/org/apache/beam/sdk/transforms/WatchTest.java |  3 ---
 .../org/apache/beam/sdk/transforms/WithFailuresTest.java    |  3 ---
 .../org/apache/beam/sdk/transforms/WithTimestampsTest.java  |  3 ---
 .../beam/sdk/transforms/display/DisplayDataEvaluator.java   |  3 ---
 .../beam/sdk/transforms/display/DisplayDataMatchers.java    |  3 ---
 .../apache/beam/sdk/transforms/display/DisplayDataTest.java |  3 ---
 .../apache/beam/sdk/transforms/join/CoGroupByKeyTest.java   |  3 ---
 .../beam/sdk/transforms/reflect/DoFnInvokersTest.java       |  1 -
 .../reflect/DoFnSignaturesSplittableDoFnTest.java           |  1 -
 .../beam/sdk/transforms/reflect/DoFnSignaturesTest.java     |  3 ---
 .../beam/sdk/transforms/reflect/OnTimerInvokersTest.java    |  3 ---
 .../reflect/testhelper/DoFnInvokersTestHelper.java          |  3 ---
 .../transforms/splittabledofn/ByteKeyRangeTrackerTest.java  |  3 ---
 .../splittabledofn/GrowableOffsetRangeTrackerTest.java      |  1 -
 .../transforms/splittabledofn/OffsetRangeTrackerTest.java   |  1 -
 .../beam/sdk/transforms/splittabledofn/SplitResultTest.java |  3 ---
 .../beam/sdk/transforms/windowing/RepeatedlyTest.java       |  3 ---
 .../apache/beam/sdk/transforms/windowing/StubTrigger.java   |  3 ---
 .../apache/beam/sdk/transforms/windowing/TriggerTest.java   |  3 ---
 .../apache/beam/sdk/transforms/windowing/WindowTest.java    |  3 ---
 .../java/org/apache/beam/sdk/util/CombineFnUtilTest.java    |  3 ---
 .../beam/sdk/util/FilePatternMatchingShardedFileTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/util/NameUtilsTest.java   |  3 ---
 .../org/apache/beam/sdk/util/NumberedShardedFileTest.java   |  3 ---
 .../src/test/java/org/apache/beam/sdk/util/RowJsonTest.java |  3 ---
 .../org/apache/beam/sdk/util/SerializableUtilsTest.java     |  3 ---
 .../test/java/org/apache/beam/sdk/util/StreamUtilsTest.java |  3 ---
 .../org/apache/beam/sdk/util/UnownedInputStreamTest.java    |  3 ---
 .../org/apache/beam/sdk/util/UnownedOutputStreamTest.java   |  3 ---
 .../org/apache/beam/sdk/util/UserCodeExceptionTest.java     |  3 ---
 .../test/java/org/apache/beam/sdk/util/ZipFilesTest.java    |  3 ---
 .../org/apache/beam/sdk/util/common/ReflectHelpersTest.java |  3 ---
 .../src/test/java/org/apache/beam/sdk/values/KVTest.java    |  3 ---
 .../src/test/java/org/apache/beam/sdk/values/RowTest.java   |  1 -
 .../org/apache/beam/sdk/values/TimestampedValueTest.java    |  3 ---
 .../java/org/apache/beam/sdk/values/TypeDescriptorTest.java |  3 ---
 .../euphoria/core/client/operator/FlatMapTest.java          |  1 -
 .../extensions/euphoria/core/client/operator/JoinTest.java  |  1 -
 .../euphoria/core/client/operator/ReduceByKeyTest.java      |  1 -
 .../euphoria/core/client/operator/SumByKeyTest.java         |  1 -
 .../extensions/euphoria/core/client/operator/TestUtils.java |  3 ---
 .../euphoria/core/client/type/TypePropagationAssert.java    |  1 -
 .../extensions/euphoria/core/client/util/IOUtilsTest.java   |  3 ---
 .../sdk/extensions/euphoria/core/testkit/FlatMapTest.java   |  3 ---
 .../beam/sdk/extensions/euphoria/core/testkit/JoinTest.java |  3 ---
 .../extensions/euphoria/core/testkit/MapElementsTest.java   |  3 ---
 .../extensions/euphoria/core/testkit/ReduceByKeyTest.java   |  3 ---
 .../sdk/extensions/euphoria/core/testkit/SumByKeyTest.java  |  3 ---
 .../core/translate/SingleJvmAccumulatorProviderTest.java    |  3 ---
 .../core/translate/collector/SingleValueCollectorTest.java  |  1 -
 .../apache/beam/sdk/transforms/windowing/WindowDesc.java    |  3 ---
 .../beam/sdk/extensions/gcp/GcpCoreApiSurfaceTest.java      |  3 ---
 .../beam/sdk/extensions/gcp/options/GcpOptionsTest.java     |  3 ---
 .../beam/sdk/extensions/gcp/storage/GcsFileSystemTest.java  |  3 ---
 .../sdk/extensions/gcp/storage/GcsPathValidatorTest.java    |  3 ---
 .../beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java  |  3 ---
 .../org/apache/beam/sdk/extensions/gcp/util/GcsUtilIT.java  |  3 ---
 .../apache/beam/sdk/extensions/gcp/util/GcsUtilTest.java    |  3 ---
 .../util/LatencyRecordingHttpRequestInitializerTest.java    |  3 ---
 .../gcp/util/RetryHttpRequestInitializerTest.java           |  3 ---
 .../gcp/util/UploadIdResponseInterceptorTest.java           |  3 ---
 .../beam/sdk/extensions/jackson/JacksonTransformsTest.java  |  3 ---
 .../apache/beam/sdk/extensions/ml/AnnotateImagesTest.java   |  3 ---
 .../apache/beam/sdk/extensions/ml/AnnotateVideoTest.java    |  3 ---
 .../beam/sdk/extensions/ml/BatchRequestForDlpTest.java      |  3 ---
 .../org/apache/beam/sdk/extensions/ml/CloudVisionIT.java    |  3 ---
 .../org/apache/beam/sdk/extensions/ml/CloudVisionTest.java  |  3 ---
 .../beam/sdk/extensions/ml/MapStringToDlpRowTest.java       |  3 ---
 .../beam/sdk/extensions/protobuf/ByteStringCoderTest.java   |  3 ---
 .../beam/sdk/extensions/protobuf/DynamicProtoCoderTest.java |  3 ---
 .../apache/beam/sdk/extensions/protobuf/ProtoCoderTest.java |  3 ---
 .../sdk/extensions/protobuf/ProtoMessageSchemaTest.java     |  3 ---
 .../sdk/extensions/protobuf/ProtoSchemaTranslatorTest.java  |  1 -
 .../sql/meta/provider/hcatalog/BeamSqlHiveSchemaTest.java   |  3 ---
 .../apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java |  3 ---
 .../org/apache/beam/sdk/extensions/sql/BeamSqlCliTest.java  |  3 ---
 .../extensions/sql/BeamSqlDslAggregationCovarianceTest.java |  3 ---
 .../extensions/sql/BeamSqlDslAggregationNullableTest.java   |  3 ---
 .../beam/sdk/extensions/sql/BeamSqlDslAggregationTest.java  |  3 ---
 .../extensions/sql/BeamSqlDslAggregationVarianceTest.java   |  3 ---
 .../org/apache/beam/sdk/extensions/sql/BeamSqlDslBase.java  |  3 ---
 .../apache/beam/sdk/extensions/sql/BeamSqlDslJoinTest.java  |  3 ---
 .../beam/sdk/extensions/sql/BeamSqlDslProjectTest.java      |  3 ---
 .../sdk/extensions/sql/BeamSqlDslSqlStdOperatorsTest.java   |  3 ---
 .../beam/sdk/extensions/sql/BeamSqlDslUdfUdafTest.java      |  3 ---
 .../apache/beam/sdk/extensions/sql/BeamSqlExplainTest.java  |  3 ---
 .../beam/sdk/extensions/sql/InferredJavaBeanSqlTest.java    |  3 ---
 .../java/org/apache/beam/sdk/extensions/sql/TestUtils.java  |  3 ---
 .../apache/beam/sdk/extensions/sql/impl/JdbcDriverTest.java |  3 ---
 .../extensions/sql/impl/parser/BeamDDLNestedTypesTest.java  |  3 ---
 .../beam/sdk/extensions/sql/impl/parser/BeamDDLTest.java    |  3 ---
 .../beam/sdk/extensions/sql/impl/planner/NodeStatsTest.java |  3 ---
 .../beam/sdk/extensions/sql/impl/rel/BaseRelTest.java       |  3 ---
 .../sql/impl/rel/BeamCoGBKJoinRelBoundedVsBoundedTest.java  |  3 ---
 .../impl/rel/BeamCoGBKJoinRelUnboundedVsUnboundedTest.java  |  3 ---
 .../sql/impl/rel/BeamEnumerableConverterTest.java           |  3 ---
 .../extensions/sql/impl/rel/BeamSideInputJoinRelTest.java   |  3 ---
 .../sql/impl/rel/BeamSideInputLookupJoinRelTest.java        |  3 ---
 .../beam/sdk/extensions/sql/impl/rel/BeamSortRelTest.java   |  3 ---
 .../sql/impl/rule/BeamAggregateProjectMergeRuleTest.java    |  3 ---
 .../sdk/extensions/sql/impl/rule/IOPushDownRuleTest.java    |  3 ---
 .../sdk/extensions/sql/impl/rule/JoinReorderingTest.java    |  6 ------
 .../sql/impl/schema/transform/BeamTransformBaseTest.java    |  3 ---
 .../sdk/extensions/sql/impl/utils/CalciteUtilsTest.java     |  3 ---
 .../BeamSqlBuiltinFunctionsIntegrationTestBase.java         |  3 ---
 .../BeamSqlDateFunctionsIntegrationTest.java                |  3 ---
 .../sdk/extensions/sql/meta/CustomTableResolverTest.java    |  3 ---
 .../sql/meta/provider/bigquery/BigQueryFilterTest.java      |  3 ---
 .../sql/meta/provider/bigquery/BigQueryTestTable.java       |  3 ---
 .../meta/provider/bigquery/BigQueryTestTableProvider.java   |  3 ---
 .../sql/meta/provider/bigtable/BigtableFilterTest.java      |  3 ---
 .../bigtable/BigtableTableCreationFailuresTest.java         |  3 ---
 .../sql/meta/provider/bigtable/BigtableTableFlatTest.java   |  3 ---
 .../sql/meta/provider/bigtable/BigtableTableIT.java         |  3 ---
 .../sql/meta/provider/bigtable/BigtableTableTestUtils.java  |  3 ---
 .../meta/provider/bigtable/BigtableTableWithRowsTest.java   |  3 ---
 .../sql/meta/provider/kafka/BeamKafkaTableProtoTest.java    |  3 ---
 .../meta/provider/kafka/BeamKafkaTableStatisticsTest.java   |  3 ---
 .../sql/meta/provider/kafka/BeamKafkaTableThriftTest.java   |  3 ---
 .../sql/meta/provider/kafka/KafkaTableProviderIT.java       |  3 ---
 .../extensions/sql/meta/provider/kafka/KafkaTestTable.java  |  3 ---
 .../sql/meta/provider/mongodb/MongoDbFilterTest.java        |  3 ---
 .../sql/meta/provider/mongodb/MongoDbReadWriteIT.java       |  3 ---
 .../sql/meta/provider/parquet/ParquetTableProviderTest.java |  3 ---
 .../sql/meta/provider/pubsub/PubsubTableProviderIT.java     |  1 -
 .../sql/meta/provider/test/TestTableProviderTest.java       |  3 ---
 .../test/TestTableProviderWithFilterAndProjectPushDown.java |  3 ---
 .../provider/test/TestTableProviderWithFilterPushDown.java  |  3 ---
 .../provider/test/TestTableProviderWithProjectPushDown.java |  3 ---
 .../extensions/sql/meta/store/InMemoryMetaStoreTest.java    |  3 ---
 .../apache/beam/sdk/extensions/sql/utils/RowAsserts.java    |  3 ---
 .../sdk/extensions/sql/zetasql/TableResolutionTest.java     |  3 ---
 .../apache/beam/sdk/extensions/sql/zetasql/TestInput.java   |  3 ---
 .../sdk/extensions/sql/zetasql/ZetaSQLPushDownTest.java     |  1 -
 .../sdk/extensions/sql/zetasql/ZetaSqlDialectSpecTest.java  |  3 ---
 .../extensions/sql/zetasql/ZetaSqlMathFunctionsTest.java    |  3 ---
 .../beam/sdk/extensions/sql/zetasql/ZetaSqlTestBase.java    |  3 ---
 .../extensions/sql/zetasql/ZetaSqlTimeFunctionsTest.java    |  3 ---
 .../java/org/apache/beam/sdk/fn/JvmInitializersTest.java    |  3 ---
 .../beam/sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java     |  3 ---
 .../BeamFnDataSizeBasedBufferingOutboundObserverTest.java   |  3 ---
 .../BeamFnDataTimeBasedBufferingOutboundObserverTest.java   |  3 ---
 .../beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java |  1 -
 .../java/org/apache/beam/sdk/fn/stream/DataStreamsTest.java |  3 ---
 .../beam/sdk/fn/stream/OutboundObserverFactoryTest.java     |  3 ---
 .../java/org/apache/beam/sdk/fn/test/TestExecutorsTest.java |  3 ---
 .../java/org/apache/beam/sdk/fn/test/TestStreamsTest.java   |  3 ---
 .../apache/beam/fn/harness/BeamFnDataReadRunnerTest.java    |  3 ---
 .../apache/beam/fn/harness/BeamFnDataWriteRunnerTest.java   |  3 ---
 .../java/org/apache/beam/fn/harness/CombineRunnersTest.java |  3 ---
 .../java/org/apache/beam/fn/harness/FlattenRunnerTest.java  |  3 ---
 .../org/apache/beam/fn/harness/FnApiDoFnRunnerTest.java     |  1 -
 .../java/org/apache/beam/fn/harness/MapFnRunnersTest.java   |  3 ---
 .../apache/beam/fn/harness/PrecombineGroupingTableTest.java |  3 ---
 .../beam/fn/harness/control/BeamFnControlClientTest.java    |  3 ---
 .../beam/fn/harness/control/FinalizeBundleHandlerTest.java  |  3 ---
 .../beam/fn/harness/control/ProcessBundleHandlerTest.java   |  1 -
 .../beam/fn/harness/data/BeamFnDataGrpcClientTest.java      |  3 ---
 .../apache/beam/fn/harness/data/FakeBeamFnTimerClient.java  |  1 -
 .../fn/harness/data/PCollectionConsumerRegistryTest.java    |  1 -
 .../beam/fn/harness/logging/BeamFnLoggingClientTest.java    |  3 ---
 .../org/apache/beam/fn/harness/state/BagUserStateTest.java  |  3 ---
 .../fn/harness/state/BeamFnStateGrpcClientCacheTest.java    |  3 ---
 .../beam/fn/harness/state/StateBackedIterableTest.java      |  1 -
 .../harness/stream/HarnessStreamObserverFactoriesTest.java  |  3 ---
 .../org/apache/beam/sdk/io/aws/coders/AwsCodersTest.java    |  3 ---
 .../beam/sdk/io/aws/dynamodb/AwsClientsProviderMock.java    |  3 ---
 .../org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java |  3 ---
 .../beam/sdk/io/aws/dynamodb/DynamoDBIOTestHelper.java      |  3 ---
 .../org/apache/beam/sdk/io/aws/options/AwsModuleTest.java   |  3 ---
 .../org/apache/beam/sdk/io/aws/s3/MatchResultMatcher.java   |  3 ---
 .../org/apache/beam/sdk/io/aws/s3/S3FileSystemTest.java     |  3 ---
 .../org/apache/beam/sdk/io/aws/s3/S3ResourceIdTest.java     |  3 ---
 .../beam/sdk/io/aws/s3/S3WritableByteChannelTest.java       |  3 ---
 .../apache/beam/sdk/io/aws/sns/PublishResultCodersTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/aws/sns/SnsIOTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/aws/sqs/SqsIOTest.java |  3 ---
 .../apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java    |  3 ---
 .../beam/sdk/io/aws2/dynamodb/DynamoDBIOTestHelper.java     |  1 -
 .../sdk/io/aws2/dynamodb/DynamoDbClientProviderMock.java    |  3 ---
 .../apache/beam/sdk/io/aws2/kinesis/AmazonKinesisMock.java  |  3 ---
 .../sdk/io/aws2/kinesis/DynamicCheckpointGeneratorTest.java |  3 ---
 .../org/apache/beam/sdk/io/aws2/kinesis/KinesisIOIT.java    |  3 ---
 .../sdk/io/aws2/kinesis/KinesisReaderCheckpointTest.java    |  3 ---
 .../apache/beam/sdk/io/aws2/kinesis/KinesisReaderTest.java  |  3 ---
 .../apache/beam/sdk/io/aws2/kinesis/KinesisServiceMock.java |  3 ---
 .../apache/beam/sdk/io/aws2/kinesis/RecordFilterTest.java   |  3 ---
 .../beam/sdk/io/aws2/kinesis/ShardCheckpointTest.java       |  3 ---
 .../beam/sdk/io/aws2/kinesis/ShardReadersPoolTest.java      |  3 ---
 .../beam/sdk/io/aws2/kinesis/ShardRecordsIteratorTest.java  |  3 ---
 .../sdk/io/aws2/kinesis/SimplifiedKinesisClientTest.java    |  3 ---
 .../sdk/io/aws2/kinesis/StartingPointShardsFinderTest.java  |  3 ---
 .../org/apache/beam/sdk/io/aws2/kinesis/TimeUtilTest.java   |  3 ---
 .../apache/beam/sdk/io/aws2/sns/MockSnsAsyncBaseClient.java |  3 ---
 .../apache/beam/sdk/io/aws2/sns/SnsClientMockErrors.java    |  3 ---
 .../apache/beam/sdk/io/aws2/sns/SnsClientMockSuccess.java   |  3 ---
 .../java/org/apache/beam/sdk/io/aws2/sns/SnsIOTest.java     |  3 ---
 .../org/apache/beam/sdk/io/aws2/sns/SnsIOWriteTest.java     |  3 ---
 .../org/apache/beam/sdk/io/aws2/sqs/EmbeddedSqsServer.java  |  3 ---
 .../apache/beam/sdk/io/aws2/sqs/SqsClientProviderMock.java  |  3 ---
 .../beam/sdk/io/azure/blobstore/AzfsResourceIdTest.java     |  3 ---
 .../apache/beam/sdk/bigqueryioperftests/BigQueryIOIT.java   |  3 ---
 .../org/apache/beam/sdk/io/cassandra/CassandraIOIT.java     |  3 ---
 .../org/apache/beam/sdk/io/cassandra/CassandraIOTest.java   |  1 -
 .../apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java   |  1 -
 .../org/apache/beam/sdk/io/clickhouse/ClickHouseIOTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/common/HashingFn.java  |  3 ---
 .../test/java/org/apache/beam/sdk/io/common/IOITHelper.java |  3 ---
 .../java/org/apache/beam/sdk/io/common/IOITHelperTest.java  |  3 ---
 .../beam/sdk/io/contextualtextio/ContextualTextIOTest.java  |  3 ---
 sdks/java/io/debezium/build.gradle                          |  1 -
 .../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java |  3 ---
 .../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java      |  3 ---
 .../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java |  3 ---
 .../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java      |  3 ---
 .../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java |  3 ---
 .../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java      |  3 ---
 .../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java |  3 ---
 .../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java      |  3 ---
 .../sdk/io/elasticsearch/ElasticsearchIOTestCommon.java     |  3 ---
 .../beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/avro/AvroIOIT.java |  3 ---
 .../java/org/apache/beam/sdk/io/parquet/ParquetIOIT.java    |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/text/TextIOIT.java |  3 ---
 .../java/org/apache/beam/sdk/io/tfrecord/TFRecordIOIT.java  |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/xml/XmlIOIT.java   |  3 ---
 .../java/org/apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java  |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java     |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryHelpersTest.java       |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryIOReadIT.java   |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryIOReadTest.java |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryIOStorageQueryIT.java  |  3 ---
 .../sdk/io/gcp/bigquery/BigQueryIOStorageQueryTest.java     |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadIT.java   |  3 ---
 .../io/gcp/bigquery/BigQueryIOStorageReadTableRowIT.java    |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadTest.java |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryIOWriteTest.java       |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryKmsKeyIT.java   |  3 ---
 .../sdk/io/gcp/bigquery/BigQuerySchemaUpdateOptionsIT.java  |  3 ---
 .../beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java  |  3 ---
 .../gcp/bigquery/BigQueryTimePartitioningClusteringIT.java  |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryToTableIT.java  |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryUtilsTest.java  |  3 ---
 .../apache/beam/sdk/io/gcp/bigtable/BigtableConfigTest.java |  3 ---
 .../org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java |  3 ---
 .../beam/sdk/io/gcp/bigtable/BigtableRowToBeamRowTest.java  |  3 ---
 .../beam/sdk/io/gcp/bigtable/BigtableServiceImplTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java    |  3 ---
 .../io/gcp/datastore/DataStoreV1SchemaIOProviderTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/datastore/DatastoreV1Test.java   |  3 ---
 .../sdk/io/gcp/datastore/EntityToRowRowToEntityTest.java    |  3 ---
 .../apache/beam/sdk/io/gcp/datastore/SplitQueryFnIT.java    |  3 ---
 .../java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java |  3 ---
 .../org/apache/beam/sdk/io/gcp/datastore/V1TestUtil.java    |  3 ---
 .../org/apache/beam/sdk/io/gcp/datastore/V1WriteIT.java     |  3 ---
 .../org/apache/beam/sdk/io/gcp/healthcare/FhirIOLROIT.java  |  3 ---
 .../org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java   |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/FhirIOTestUtil.java   |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/FhirIOWriteIT.java    |  3 ---
 .../beam/sdk/io/gcp/healthcare/HL7V2MessagePagesTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/HL7v2IOReadIT.java    |  3 ---
 .../beam/sdk/io/gcp/healthcare/HL7v2IOReadWriteIT.java      |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/HL7v2IOTestUtil.java  |  3 ---
 .../apache/beam/sdk/io/gcp/healthcare/HL7v2IOWriteIT.java   |  3 ---
 .../apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClientTest.java |  3 ---
 .../apache/beam/sdk/io/gcp/pubsub/PubsubIOExternalTest.java |  3 ---
 .../org/apache/beam/sdk/io/gcp/pubsub/PubsubIOTest.java     |  3 ---
 .../apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java |  3 ---
 .../beam/sdk/io/gcp/pubsub/PubsubMessageToRowTest.java      |  3 ---
 .../apache/beam/sdk/io/gcp/pubsub/PubsubTestClientTest.java |  3 ---
 .../beam/sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java     |  3 ---
 .../beam/sdk/io/gcp/pubsub/PubsubUnboundedSourceTest.java   |  3 ---
 .../beam/sdk/io/gcp/pubsublite/AddUuidsTransformTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/pubsublite/FakeSerializable.java |  3 ---
 .../beam/sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java      |  3 ---
 .../apache/beam/sdk/io/gcp/spanner/FakeServiceFactory.java  |  3 ---
 .../beam/sdk/io/gcp/spanner/MutationKeyEncoderTest.java     |  3 ---
 .../beam/sdk/io/gcp/spanner/MutationSizeEstimatorTest.java  |  3 ---
 .../org/apache/beam/sdk/io/gcp/spanner/OrderedCodeTest.java |  3 ---
 .../beam/sdk/io/gcp/spanner/ReadSpannerSchemaTest.java      |  3 ---
 .../apache/beam/sdk/io/gcp/spanner/SpannerAccessorTest.java |  3 ---
 .../apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java   |  3 ---
 .../apache/beam/sdk/io/gcp/spanner/SpannerIOWriteTest.java  |  3 ---
 .../org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java   |  3 ---
 .../org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java  |  3 ---
 .../org/apache/beam/sdk/io/gcp/storage/GcsKmsKeyIT.java     |  3 ---
 .../apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java  |  3 ---
 .../apache/beam/sdk/io/gcp/testing/BigqueryMatcherTest.java |  3 ---
 .../beam/sdk/io/hadoop/SerializableConfigurationTest.java   |  3 ---
 .../beam/sdk/io/hdfs/HadoopFileSystemRegistrarTest.java     |  3 ---
 .../org/apache/beam/sdk/io/hdfs/HadoopFileSystemTest.java   |  3 ---
 .../org/apache/beam/sdk/io/hdfs/HadoopResourceIdTest.java   |  3 ---
 .../io/hadoop/format/ConfigurableEmployeeInputFormat.java   |  3 ---
 .../java/org/apache/beam/sdk/io/hadoop/format/Employee.java |  3 ---
 .../beam/sdk/io/hadoop/format/EmployeeInputFormat.java      |  3 ---
 .../beam/sdk/io/hadoop/format/EmployeeOutputFormat.java     |  3 ---
 .../beam/sdk/io/hadoop/format/HDFSSynchronizationTest.java  |  3 ---
 .../sdk/io/hadoop/format/HadoopFormatIOCassandraIT.java     |  3 ---
 .../sdk/io/hadoop/format/HadoopFormatIOCassandraTest.java   |  3 ---
 .../beam/sdk/io/hadoop/format/HadoopFormatIOElasticIT.java  |  3 ---
 .../apache/beam/sdk/io/hadoop/format/HadoopFormatIOIT.java  |  3 ---
 .../beam/sdk/io/hadoop/format/HadoopFormatIOReadTest.java   |  1 -
 .../io/hadoop/format/HadoopFormatIOSequenceFileTest.java    |  3 ---
 .../beam/sdk/io/hadoop/format/HadoopFormatIOWriteTest.java  |  3 ---
 .../beam/sdk/io/hadoop/format/IterableCombinerTest.java     |  3 ---
 .../io/hadoop/format/ReuseObjectsEmployeeInputFormat.java   |  3 ---
 .../apache/beam/sdk/io/hadoop/format/TestRowDBWritable.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/hbase/HBaseIOIT.java   |  3 ---
 .../test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java |  3 ---
 .../apache/beam/sdk/io/hcatalog/HCatalogBeamSchemaTest.java |  3 ---
 .../java/org/apache/beam/sdk/io/hcatalog/HCatalogIOIT.java  |  3 ---
 .../org/apache/beam/sdk/io/hcatalog/HCatalogIOTest.java     |  3 ---
 .../apache/beam/sdk/io/hcatalog/HiveDatabaseTestHelper.java |  3 ---
 .../org/apache/beam/sdk/io/hcatalog/SchemaUtilsTest.java    |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/jdbc/JdbcTestHelper.java    |  3 ---
 .../java/org/apache/beam/sdk/io/jdbc/SchemaUtilTest.java    |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java |  1 -
 .../ConfluentSchemaRegistryDeserializerProviderTest.java    |  1 -
 .../io/kafka/CustomTimestampPolicyWithLimitedDelayTest.java |  3 ---
 .../org/apache/beam/sdk/io/kafka/KafkaIOExternalTest.java   |  1 -
 .../test/java/org/apache/beam/sdk/io/kafka/KafkaIOIT.java   |  3 ---
 .../test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java |  3 ---
 .../java/org/apache/beam/sdk/io/kafka/KafkaIOUtilsTest.java |  1 -
 .../apache/beam/sdk/io/kafka/ProducerRecordCoderTest.java   |  1 -
 .../org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java |  1 -
 .../org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java   |  3 ---
 .../beam/sdk/io/kinesis/DynamicCheckpointGeneratorTest.java |  3 ---
 .../java/org/apache/beam/sdk/io/kinesis/KinesisIOIT.java    |  3 ---
 .../apache/beam/sdk/io/kinesis/KinesisMockWriteTest.java    |  3 ---
 .../beam/sdk/io/kinesis/KinesisReaderCheckpointTest.java    |  3 ---
 .../org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java   |  3 ---
 .../org/apache/beam/sdk/io/kinesis/KinesisServiceMock.java  |  3 ---
 .../org/apache/beam/sdk/io/kinesis/RecordFilterTest.java    |  3 ---
 .../org/apache/beam/sdk/io/kinesis/ShardCheckpointTest.java |  3 ---
 .../apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java    |  3 ---
 .../beam/sdk/io/kinesis/ShardRecordsIteratorTest.java       |  3 ---
 .../beam/sdk/io/kinesis/SimplifiedKinesisClientTest.java    |  3 ---
 .../beam/sdk/io/kinesis/StartingPointShardsFinderTest.java  |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/kudu/KuduIOIT.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java   |  3 ---
 .../org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java |  3 ---
 .../java/org/apache/beam/sdk/io/mongodb/MongoDBIOIT.java    |  3 ---
 .../java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java  |  3 ---
 .../test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java   |  3 ---
 .../java/org/apache/beam/sdk/io/parquet/ParquetIOTest.java  |  3 ---
 .../org/apache/beam/sdk/io/rabbitmq/ExchangeTestPlan.java   |  3 ---
 .../org/apache/beam/sdk/io/rabbitmq/RabbitMqIOTest.java     |  3 ---
 .../test/java/org/apache/beam/sdk/io/redis/RedisIOTest.java |  3 ---
 .../beam/sdk/io/snowflake/test/BatchSnowflakeIOIT.java      |  3 ---
 .../sdk/io/snowflake/test/FakeSnowflakeBasicDataSource.java |  3 ---
 .../io/snowflake/test/FakeSnowflakeBatchServiceImpl.java    |  3 ---
 .../beam/sdk/io/snowflake/test/FakeSnowflakeDatabase.java   |  3 ---
 .../snowflake/test/FakeSnowflakeStreamingServiceImpl.java   |  3 ---
 .../beam/sdk/io/snowflake/test/StreamingSnowflakeIOIT.java  |  3 ---
 .../org/apache/beam/sdk/io/snowflake/test/TestUtils.java    |  1 -
 .../io/snowflake/test/unit/DataSourceConfigurationTest.java |  3 ---
 .../io/snowflake/test/unit/read/SnowflakeIOReadTest.java    |  1 -
 .../io/snowflake/test/unit/write/CreateDispositionTest.java |  1 -
 .../test/unit/write/QueryDispositionLocationTest.java       |  1 -
 .../io/snowflake/test/unit/write/SchemaDispositionTest.java |  1 -
 .../io/snowflake/test/unit/write/SnowflakeIOWriteTest.java  |  1 -
 .../io/snowflake/test/unit/write/StreamingWriteTest.java    |  1 -
 .../org/apache/beam/sdk/io/solr/JavaBinCodecCoderTest.java  |  3 ---
 .../test/java/org/apache/beam/sdk/io/solr/SolrIOTest.java   |  1 -
 .../apache/beam/sdk/io/splunk/SplunkEventWriterTest.java    |  3 ---
 .../java/org/apache/beam/sdk/io/splunk/SplunkIOTest.java    |  3 ---
 .../apache/beam/sdk/io/synthetic/BundleSplitterTest.java    |  1 -
 .../beam/sdk/io/synthetic/SyntheticBoundedSourceTest.java   |  3 ---
 .../beam/sdk/io/synthetic/SyntheticUnboundedSourceTest.java |  3 ---
 .../java/org/apache/beam/sdk/io/thrift/ThriftIOTest.java    |  3 ---
 .../test/java/org/apache/beam/sdk/io/tika/TikaIOTest.java   |  3 ---
 .../test/java/org/apache/beam/sdk/io/xml/JAXBCoderTest.java |  3 ---
 .../src/test/java/org/apache/beam/sdk/io/xml/XmlIOTest.java |  3 ---
 .../test/java/org/apache/beam/sdk/io/xml/XmlSourceTest.java |  3 ---
 .../beam/sdk/testing/expansion/TestExpansionService.java    |  1 -
 .../java/org/apache/beam/sdk/nexmark/NexmarkUtilsTest.java  |  1 -
 .../org/apache/beam/sdk/nexmark/PerfsToBigQueryTest.java    |  3 ---
 .../apache/beam/sdk/testutils/fakes/FakeBigQueryClient.java |  3 ---
 .../sdk/testutils/fakes/FakeBigQueryResultsPublisher.java   |  3 ---
 .../beam/sdk/testutils/jvmverification/JvmVerification.java |  3 ---
 .../testutils/publishing/BigQueryResultsPublisherTest.java  |  3 ---
 845 files changed, 16 insertions(+), 2259 deletions(-)


Mime
View raw message