This is an automated email from the ASF dual-hosted git repository. ibzib pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from b2ad4dd Merge pull request #13670 from [BEAM-11569] Clone ad-m/github-push-action into Beam repository to comply with Apache security requirements new 9ebdc8a replace Assert.asserThat with MacherAssert.assertThat across entire codebase new 3915c3f [BEAM-11572] Add lint rule to avoid Assert.assertThat usage new 9df5db9 Fix Assertion in Nexmark (non-test) class. new 60834ae Merge pull request #13673 from anantdamle/beam_11572_fix_assertThat The 30118 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: .../examples/complete/game/LeaderBoardTest.java | 2 +- .../cookbook/CombinePerKeyExamplesTest.java | 13 +++++------ .../beam/learning/katas/util/ContainsKvs.java | 2 +- .../core/construction/CoderTranslationTest.java | 2 +- .../runners/core/construction/CommonCoderTest.java | 2 +- .../CreatePCollectionViewTranslationTest.java | 2 +- .../DeduplicatedFlattenFactoryTest.java | 2 +- .../construction/DefaultArtifactResolverTest.java | 2 +- .../EmptyFlattenAsCreateFactoryTest.java | 2 +- .../core/construction/EnvironmentsTest.java | 2 +- .../ExecutableStageTranslationTest.java | 2 +- .../construction/ForwardingPTransformTest.java | 2 +- .../construction/GroupByKeyTranslationTest.java | 2 +- .../runners/core/construction/ModelCodersTest.java | 2 +- .../core/construction/MorePipelineTest.java | 2 +- .../construction/PCollectionTranslationTest.java | 2 +- .../core/construction/PTransformMatchersTest.java | 2 +- .../construction/PTransformReplacementsTest.java | 2 +- .../construction/PTransformTranslationTest.java | 2 +- .../core/construction/ParDoTranslationTest.java | 2 +- .../PipelineOptionsTranslationTest.java | 2 +- .../core/construction/PipelineTranslationTest.java | 2 +- .../core/construction/ReadTranslationTest.java | 2 +- .../construction/RehydratedComponentsTest.java | 2 +- .../core/construction/ReplacementOutputsTest.java | 2 +- .../construction/ReshuffleTranslationTest.java | 2 +- .../core/construction/SchemaTranslationTest.java | 2 +- .../core/construction/SdkComponentsTest.java | 2 +- .../SingleInputOutputOverrideFactoryTest.java | 2 +- .../construction/TestStreamTranslationTest.java | 2 +- .../core/construction/TransformInputsTest.java | 2 +- .../core/construction/TriggerTranslationTest.java | 2 +- .../core/construction/UnconsumedReadsTest.java | 2 +- .../core/construction/ValidateRunnerXlangTest.java | 2 +- .../WindowingStrategyTranslationTest.java | 2 +- .../construction/WriteFilesTranslationTest.java | 2 +- .../construction/graph/ExecutableStageTest.java | 2 +- .../core/construction/graph/FusedPipelineTest.java | 2 +- .../graph/GreedyPipelineFuserTest.java | 2 +- .../construction/graph/GreedyStageFuserTest.java | 2 +- .../graph/ImmutableExecutableStageTest.java | 2 +- .../core/construction/graph/NetworksTest.java | 2 +- .../construction/graph/OutputDeduplicatorTest.java | 2 +- .../construction/graph/ProtoOverridesTest.java | 2 +- .../construction/graph/QueryablePipelineTest.java | 2 +- .../runners/core/InMemoryStateInternalsTest.java | 2 +- .../runners/core/InMemoryTimerInternalsTest.java | 2 +- .../core/LateDataDroppingDoFnRunnerTest.java | 2 +- .../beam/runners/core/LateDataUtilsTest.java | 2 +- ...BoundedSplittableProcessElementInvokerTest.java | 2 +- .../beam/runners/core/ReduceFnRunnerTest.java | 2 +- .../beam/runners/core/SideInputHandlerTest.java | 2 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 2 +- .../SimplePushbackSideInputDoFnRunnerTest.java | 2 +- .../runners/core/SplittableParDoProcessFnTest.java | 2 +- .../beam/runners/core/StateNamespacesTest.java | 2 +- .../beam/runners/core/TimerInternalsTest.java | 2 +- .../beam/runners/core/WindowMatchersTest.java | 2 +- .../beam/runners/core/metrics/CounterCellTest.java | 2 +- .../beam/runners/core/metrics/DirtyStateTest.java | 2 +- .../runners/core/metrics/DistributionCellTest.java | 2 +- .../core/metrics/ExecutionStateSamplerTest.java | 2 +- .../core/metrics/ExecutionStateTrackerTest.java | 2 +- .../beam/runners/core/metrics/GaugeCellTest.java | 2 +- .../core/metrics/MetricsContainerImplTest.java | 2 +- .../core/metrics/MetricsContainerStepMapTest.java | 2 +- .../beam/runners/core/metrics/MetricsMapTest.java | 2 +- .../runners/core/metrics/MetricsPusherTest.java | 2 +- .../core/metrics/MonitoringInfoConstantsTest.java | 2 +- .../core/metrics/SimpleStateRegistryTest.java | 2 +- .../triggers/AfterWatermarkStateMachineTest.java | 2 +- .../core/triggers/FinishedTriggersBitSetTest.java | 2 +- .../core/triggers/FinishedTriggersSetTest.java | 2 +- .../core/triggers/NeverStateMachineTest.java | 2 +- .../core/triggers/TriggerStateMachinesTest.java | 2 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 2 +- .../runners/direct/CloningBundleFactoryTest.java | 2 +- .../beam/runners/direct/CommittedResultTest.java | 2 +- .../CopyOnAccessInMemoryStateInternalsTest.java | 2 +- .../runners/direct/DirectGraphVisitorTest.java | 2 +- .../DirectGroupByKeyOverrideFactoryTest.java | 2 +- .../beam/runners/direct/DirectMetricsTest.java | 2 +- .../runners/direct/DirectRunnerApiSurfaceTest.java | 2 +- .../beam/runners/direct/DirectRunnerTest.java | 2 +- .../runners/direct/DirectTimerInternalsTest.java | 2 +- .../direct/DirectTransformExecutorTest.java | 2 +- ...cycleManagerRemovingTransformEvaluatorTest.java | 2 +- .../runners/direct/DoFnLifecycleManagerTest.java | 2 +- .../beam/runners/direct/EvaluationContextTest.java | 2 +- .../direct/FlattenEvaluatorFactoryTest.java | 2 +- .../direct/GroupByKeyEvaluatorFactoryTest.java | 2 +- .../direct/GroupByKeyOnlyEvaluatorFactoryTest.java | 2 +- .../ImmutabilityCheckingBundleFactoryTest.java | 2 +- .../direct/ImmutableListBundleFactoryTest.java | 2 +- .../direct/ImpulseEvaluatorFactoryTest.java | 2 +- .../direct/KeyedPValueTrackingVisitorTest.java | 2 +- .../beam/runners/direct/MultiStepCombineTest.java | 2 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 2 +- .../runners/direct/SideInputContainerTest.java | 2 +- .../direct/StatefulParDoEvaluatorFactoryTest.java | 2 +- .../runners/direct/StepTransformResultTest.java | 2 +- .../direct/TestStreamEvaluatorFactoryTest.java | 2 +- .../direct/UnboundedReadDeduplicatorTest.java | 2 +- .../direct/UnboundedReadEvaluatorFactoryTest.java | 2 +- .../runners/direct/ViewEvaluatorFactoryTest.java | 2 +- .../direct/WatermarkCallbackExecutorTest.java | 2 +- .../beam/runners/direct/WatermarkManagerTest.java | 2 +- .../runners/direct/WindowEvaluatorFactoryTest.java | 2 +- .../direct/WriteWithShardingFactoryTest.java | 2 +- .../runners/flink/FlinkTransformOverridesTest.java | 2 +- .../wrappers/streaming/DedupingOperatorTest.java | 2 +- .../dataflow/BatchStatefulParDoOverridesTest.java | 2 +- .../runners/dataflow/BatchViewOverridesTest.java | 2 +- .../dataflow/DataflowPTransformMatchersTest.java | 2 +- .../dataflow/DataflowPipelineTranslatorTest.java | 2 +- .../runners/dataflow/DataflowRunnerInfoTest.java | 2 +- .../dataflow/PrimitiveParDoSingleFactoryTest.java | 2 +- .../runners/dataflow/TestDataflowRunnerTest.java | 2 +- .../options/DataflowPipelineDebugOptionsTest.java | 2 +- .../options/DataflowProfilingOptionsTest.java | 2 +- .../runners/dataflow/util/PackageUtilTest.java | 2 +- .../beam/runners/dataflow/util/StructsTest.java | 25 +++++++++++----------- .../dataflow/harness/test/TestStreamsTest.java | 2 +- .../dataflow/worker/AvroByteReaderFactoryTest.java | 5 +++-- .../dataflow/worker/AvroByteSinkFactoryTest.java | 3 ++- .../dataflow/worker/BatchDataflowWorkerTest.java | 2 +- .../worker/BatchModeExecutionContextTest.java | 2 +- .../dataflow/worker/ConcatReaderFactoryTest.java | 2 +- .../runners/dataflow/worker/ConcatReaderTest.java | 2 +- .../ContextActivationObserverRegistryTest.java | 2 +- ...CreateIsmShardKeyAndSortKeyDoFnFactoryTest.java | 2 +- .../DataflowElementExecutionTrackerTest.java | 2 +- .../worker/DataflowExecutionStateTrackerTest.java | 2 +- .../worker/DataflowSideInputReadCounterTest.java | 2 +- .../worker/DataflowWorkerHarnessHelperTest.java | 2 +- .../dataflow/worker/DefaultParDoFnFactoryTest.java | 2 +- .../dataflow/worker/DeltaCounterCellTest.java | 2 +- .../dataflow/worker/DoFnInstanceManagersTest.java | 2 +- .../runners/dataflow/worker/FilepatternsTest.java | 2 +- .../GroupAlsoByWindowParDoFnFactoryTest.java | 2 +- .../dataflow/worker/InMemoryReaderFactoryTest.java | 3 ++- .../IntrinsicMapTaskExecutorFactoryTest.java | 2 +- .../worker/IntrinsicMapTaskExecutorTest.java | 2 +- .../runners/dataflow/worker/IsmFormatTest.java | 2 +- .../dataflow/worker/IsmSideInputReaderTest.java | 2 +- .../dataflow/worker/LogRecordMatcherTest.java | 2 +- .../beam/runners/dataflow/worker/LogSaverTest.java | 2 +- ...tContextActivationObserverRegistrationTest.java | 2 +- .../worker/PairWithConstantKeyDoFnFactoryTest.java | 2 +- .../worker/PartialGroupByKeyParDoFnsTest.java | 2 +- .../runners/dataflow/worker/ReaderFactoryTest.java | 6 ++++-- ...ReifyTimestampAndWindowsParDoFnFactoryTest.java | 2 +- ...essCoderCloudObjectTranslatorRegistrarTest.java | 2 +- .../dataflow/worker/ShuffleReaderFactoryTest.java | 3 ++- .../dataflow/worker/ShuffleSinkFactoryTest.java | 3 ++- .../runners/dataflow/worker/SimpleParDoFnTest.java | 2 +- .../runners/dataflow/worker/SinkRegistryTest.java | 5 +++-- .../worker/SourceOperationExecutorFactoryTest.java | 2 +- .../runners/dataflow/worker/StateFetcherTest.java | 2 +- .../worker/StreamingDataflowWorkerTest.java | 2 +- .../worker/StreamingGroupAlsoByWindowFnsTest.java | 2 +- ...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 2 +- .../worker/StreamingModeExecutionContextTest.java | 2 +- ...eamingPCollectionViewWriterDoFnFactoryTest.java | 2 +- .../worker/StreamingSideInputDoFnRunnerTest.java | 2 +- .../worker/StreamingSideInputFetcherTest.java | 2 +- .../worker/StreamingStepMetricsContainerTest.java | 2 +- .../ToIsmRecordForMultimapDoFnFactoryTest.java | 2 +- .../dataflow/worker/UserParDoFnFactoryTest.java | 2 +- .../dataflow/worker/ValuesDoFnFactoryTest.java | 2 +- .../dataflow/worker/WindmillKeyedWorkItemTest.java | 2 +- .../worker/WindmillStateInternalsTest.java | 2 +- .../dataflow/worker/WindmillStateReaderTest.java | 2 +- .../worker/WindmillTimerInternalsTest.java | 2 +- .../dataflow/worker/WorkItemStatusClientTest.java | 2 +- .../dataflow/worker/counters/CounterSetTest.java | 2 +- .../fn/control/BeamFnMapTaskExecutorTest.java | 2 +- .../RegisterAndProcessBundleOperationTest.java | 2 +- .../worker/fn/data/BeamFnDataGrpcServiceTest.java | 2 +- .../fn/data/RemoteGrpcPortReadOperationTest.java | 2 +- .../fn/data/RemoteGrpcPortWriteOperationTest.java | 2 +- .../fn/logging/BeamFnLoggingServiceTest.java | 2 +- .../fn/stream/ServerStreamObserverFactoryTest.java | 2 +- .../graph/CloneAmbiguousFlattensFunctionTest.java | 2 +- .../CreateRegisterFnOperationFunctionTest.java | 2 +- .../graph/DeduceNodeLocationsFunctionTest.java | 2 +- ...tFetchAndFilterStreamingSideInputNodesTest.java | 2 +- .../worker/graph/MapTaskToNetworkFunctionTest.java | 2 +- .../dataflow/worker/graph/NetworksTest.java | 2 +- .../RemoveFlattenInstructionsFunctionTest.java | 2 +- .../ReplacePgbkWithPrecombineFunctionTest.java | 2 +- .../DataflowWorkerLoggingInitializerTest.java | 2 +- .../JulHandlerPrintStreamAdapterFactoryTest.java | 2 +- .../worker/profiler/ScopedProfilerTest.java | 2 +- .../dataflow/worker/status/ThreadzServletTest.java | 2 +- .../worker/status/WorkerStatusPagesTest.java | 2 +- .../worker/util/BatchGroupAlsoByWindowFnsTest.java | 2 +- .../BatchGroupAlsoByWindowReshuffleDoFnTest.java | 2 +- .../worker/util/GroupAlsoByWindowProperties.java | 2 +- .../dataflow/worker/util/MemoryMonitorTest.java | 2 +- .../worker/util/ScalableBloomFilterTest.java | 2 +- .../dataflow/worker/util/TimerOrElementTest.java | 2 +- .../worker/BatchingShuffleEntryReaderTest.java | 2 +- .../worker/CachingShuffleBatchReaderTest.java | 2 +- .../util/common/worker/FlattenOperationTest.java | 5 ++--- .../util/common/worker/GroupingTablesTest.java | 2 +- .../util/common/worker/MapTaskExecutorTest.java | 2 +- .../util/common/worker/OutputReceiverTest.java | 5 +++-- .../util/common/worker/ParDoOperationTest.java | 2 +- .../util/common/worker/ReadOperationTest.java | 2 +- .../util/common/worker/ShuffleEntryTest.java | 2 +- .../util/common/worker/WriteOperationTest.java | 2 +- .../runners/fnexecution/ServerFactoryTest.java | 2 +- .../control/DefaultJobBundleFactoryTest.java | 7 +++--- .../control/FnApiControlClientPoolServiceTest.java | 2 +- .../control/FnApiControlClientTest.java | 2 +- ...gleEnvironmentInstanceJobBundleFactoryTest.java | 2 +- .../fnexecution/data/GrpcDataServiceTest.java | 2 +- .../environment/ProcessEnvironmentFactoryTest.java | 2 +- .../environment/ProcessManagerTest.java | 2 +- .../environment/RemoteEnvironmentTest.java | 2 +- .../logging/GrpcLoggingServiceTest.java | 2 +- .../StaticGrpcProvisionServiceTest.java | 2 +- .../fnexecution/state/GrpcStateServiceTest.java | 2 +- .../translation/PipelineTranslatorUtilsTest.java | 2 +- .../beam/runners/local/StructuralKeyTest.java | 18 ++++++++-------- .../runners/spark/GlobalWatermarkHolderTest.java | 2 +- .../beam/runners/spark/SparkPipelineStateTest.java | 2 +- .../runners/spark/SparkRunnerDebuggerTest.java | 2 +- .../metrics/sink/SparkMetricsSinkTest.java | 2 +- .../spark/io/ReaderToIteratorAdapterTest.java | 2 +- .../runners/spark/metrics/SparkBeamMetricTest.java | 2 +- .../spark/metrics/SparkMetricsPusherTest.java | 2 +- .../metrics/sink/SparkMetricsSinkTest.java | 2 +- .../metrics/BeamMetricTest.java | 2 +- .../translation/batch/GroupByKeyTest.java | 2 +- .../translation/streaming/CreateStreamTest.java | 2 +- .../ResumeFromCheckpointStreamingTest.java | 2 +- .../streaming/SparkCoGroupByKeyStreamingTest.java | 2 +- .../streaming/StreamingSourceMetricsTest.java | 2 +- .../streaming/TrackStreamingSourcesTest.java | 2 +- .../src/main/resources/beam/checkstyle.xml | 9 ++++++++ .../apache/beam/sdk/testing/CoderProperties.java | 2 +- .../apache/beam/sdk/testing/CombineFnTester.java | 2 +- .../java/org/apache/beam/sdk/testing/PAssert.java | 2 +- .../apache/beam/sdk/testing/SourceTestUtils.java | 2 +- .../apache/beam/sdk/testing/WindowFnTestUtils.java | 2 +- .../java/org/apache/beam/sdk/PipelineTest.java | 2 +- .../org/apache/beam/sdk/coders/AvroCoderTest.java | 2 +- .../beam/sdk/coders/BigDecimalCoderTest.java | 2 +- .../beam/sdk/coders/BigEndianIntegerCoderTest.java | 2 +- .../beam/sdk/coders/BigEndianLongCoderTest.java | 2 +- .../beam/sdk/coders/BigIntegerCoderTest.java | 2 +- .../apache/beam/sdk/coders/BitSetCoderTest.java | 2 +- .../apache/beam/sdk/coders/ByteArrayCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/ByteCoderTest.java | 2 +- .../java/org/apache/beam/sdk/coders/CoderTest.java | 2 +- .../beam/sdk/coders/CollectionCoderTest.java | 2 +- .../apache/beam/sdk/coders/DefaultCoderTest.java | 2 +- .../apache/beam/sdk/coders/DelegateCoderTest.java | 2 +- .../apache/beam/sdk/coders/DoubleCoderTest.java | 2 +- .../apache/beam/sdk/coders/DurationCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/FloatCoderTest.java | 2 +- .../apache/beam/sdk/coders/InstantCoderTest.java | 2 +- .../apache/beam/sdk/coders/IterableCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/KvCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/ListCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/MapCoderTest.java | 2 +- .../apache/beam/sdk/coders/NullableCoderTest.java | 2 +- .../sdk/coders/PCollectionCustomCoderTest.java | 2 +- .../beam/sdk/coders/SerializableCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/SetCoderTest.java | 2 +- .../beam/sdk/coders/StringDelegateCoderTest.java | 2 +- .../beam/sdk/coders/StringUtf8CoderTest.java | 2 +- .../beam/sdk/coders/StructuredCoderTest.java | 11 +++++----- .../beam/sdk/coders/TextualIntegerCoderTest.java | 2 +- .../apache/beam/sdk/coders/VarIntCoderTest.java | 2 +- .../apache/beam/sdk/coders/VarLongCoderTest.java | 2 +- .../org/apache/beam/sdk/coders/VoidCoderTest.java | 2 +- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 2 +- .../org/apache/beam/sdk/io/AvroSourceTest.java | 2 +- .../sdk/io/BoundedReadFromUnboundedSourceTest.java | 2 +- .../apache/beam/sdk/io/CompressedSourceTest.java | 2 +- .../org/apache/beam/sdk/io/CountingSourceTest.java | 2 +- .../org/apache/beam/sdk/io/FileBasedSinkTest.java | 2 +- .../apache/beam/sdk/io/FileBasedSourceTest.java | 2 +- .../org/apache/beam/sdk/io/FileSystemsTest.java | 2 +- .../beam/sdk/io/LocalFileSystemRegistrarTest.java | 2 +- .../apache/beam/sdk/io/LocalFileSystemTest.java | 2 +- .../org/apache/beam/sdk/io/TextIOReadTest.java | 2 +- .../org/apache/beam/sdk/io/TextIOWriteTest.java | 2 +- .../org/apache/beam/sdk/io/WriteFilesTest.java | 2 +- .../io/range/ByteKeyRangeEstimateFractionTest.java | 2 +- .../io/range/ByteKeyRangeInterpolateKeyTest.java | 2 +- .../apache/beam/sdk/io/range/ByteKeyRangeTest.java | 2 +- .../org/apache/beam/sdk/io/range/ByteKeyTest.java | 2 +- .../org/apache/beam/sdk/metrics/MetricsTest.java | 2 +- .../sdk/options/PipelineOptionsFactoryTest.java | 2 +- .../sdk/options/ProxyInvocationHandlerTest.java | 2 +- .../beam/sdk/runners/PipelineRunnerTest.java | 2 +- .../beam/sdk/runners/TransformHierarchyTest.java | 2 +- .../apache/beam/sdk/runners/TransformTreeTest.java | 2 +- .../apache/beam/sdk/schemas/SchemaCoderTest.java | 2 +- .../sdk/schemas/transforms/CastValidatorTest.java | 2 +- .../beam/sdk/schemas/transforms/CoGroupTest.java | 2 +- .../beam/sdk/schemas/transforms/GroupTest.java | 2 +- .../beam/sdk/schemas/utils/SchemaZipFoldTest.java | 2 +- .../apache/beam/sdk/state/StateContextsTest.java | 2 +- .../beam/sdk/testing/CoderPropertiesTest.java | 2 +- .../beam/sdk/testing/CombineFnTesterTest.java | 2 +- .../org/apache/beam/sdk/testing/PAssertTest.java | 2 +- .../beam/sdk/testing/PaneExtractorsTest.java | 2 +- .../beam/sdk/testing/SerializableMatchersTest.java | 2 +- .../apache/beam/sdk/testing/StaticWindowsTest.java | 2 +- .../apache/beam/sdk/testing/TestPipelineTest.java | 2 +- .../beam/sdk/testing/WindowSupplierTest.java | 2 +- .../apache/beam/sdk/transforms/CombineFnsTest.java | 2 +- .../apache/beam/sdk/transforms/CombineTest.java | 2 +- .../org/apache/beam/sdk/transforms/CreateTest.java | 2 +- .../apache/beam/sdk/transforms/DistinctTest.java | 2 +- .../org/apache/beam/sdk/transforms/DoFnTest.java | 2 +- .../apache/beam/sdk/transforms/DoFnTesterTest.java | 2 +- .../apache/beam/sdk/transforms/FlattenTest.java | 2 +- .../apache/beam/sdk/transforms/GroupByKeyTest.java | 2 +- .../apache/beam/sdk/transforms/PTransformTest.java | 2 +- .../org/apache/beam/sdk/transforms/ParDoTest.java | 2 +- .../org/apache/beam/sdk/transforms/ReifyTest.java | 2 +- .../beam/sdk/transforms/ReifyTimestampsTest.java | 2 +- .../apache/beam/sdk/transforms/ReshuffleTest.java | 2 +- .../beam/sdk/transforms/SimpleFunctionTest.java | 2 +- .../beam/sdk/transforms/WithFailuresTest.java | 2 +- .../display/DisplayDataEvaluatorTest.java | 2 +- .../display/DisplayDataMatchersTest.java | 2 +- .../sdk/transforms/display/DisplayDataTest.java | 2 +- .../beam/sdk/transforms/join/CoGbkResultTest.java | 2 +- .../beam/sdk/transforms/join/CoGroupByKeyTest.java | 2 +- .../beam/sdk/transforms/join/UnionCoderTest.java | 2 +- .../sdk/transforms/reflect/DoFnInvokersTest.java | 2 +- .../sdk/transforms/reflect/DoFnSignaturesTest.java | 2 +- .../transforms/reflect/OnTimerInvokersTest.java | 2 +- .../sdk/transforms/windowing/FixedWindowsTest.java | 2 +- .../transforms/windowing/IntervalWindowTest.java | 2 +- .../sdk/transforms/windowing/RepeatedlyTest.java | 2 +- .../sdk/transforms/windowing/SessionsTest.java | 2 +- .../transforms/windowing/SlidingWindowsTest.java | 2 +- .../beam/sdk/transforms/windowing/WindowTest.java | 2 +- .../org/apache/beam/sdk/util/ApiSurfaceTest.java | 2 +- .../BufferedElementCountingOutputStreamTest.java | 2 +- .../apache/beam/sdk/util/FluentBackoffTest.java | 2 +- .../org/apache/beam/sdk/util/HistogramTest.java | 2 +- .../org/apache/beam/sdk/util/MoreFuturesTest.java | 2 +- .../org/apache/beam/sdk/util/ReleaseInfoTest.java | 2 +- .../beam/sdk/util/UserCodeExceptionTest.java | 2 +- .../java/org/apache/beam/sdk/util/VarIntTest.java | 2 +- .../apache/beam/sdk/util/WindowedValueTest.java | 2 +- .../org/apache/beam/sdk/util/ZipFilesTest.java | 2 +- .../beam/sdk/util/common/ReflectHelpersTest.java | 2 +- .../java/org/apache/beam/sdk/values/KVTest.java | 2 +- .../beam/sdk/values/PCollectionListTest.java | 2 +- .../beam/sdk/values/PCollectionTupleTest.java | 2 +- .../org/apache/beam/sdk/values/TupleTagTest.java | 2 +- .../beam/sdk/values/TypeDescriptorsTest.java | 2 +- .../apache/beam/sdk/values/TypedPValueTest.java | 2 +- .../beam/sdk/expansion/service/ExternalTest.java | 2 +- .../gcp/storage/GcsFileSystemRegistrarTest.java | 2 +- .../extensions/gcp/storage/GcsFileSystemTest.java | 2 +- .../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 2 +- ...LatencyRecordingHttpRequestInitializerTest.java | 2 +- .../gcp/util/RetryHttpRequestInitializerTest.java | 2 +- .../sdk/extensions/gcp/util/gcsfs/GcsPathTest.java | 2 +- .../extensions/protobuf/ByteStringCoderTest.java | 2 +- .../sdk/extensions/protobuf/ProtobufUtilTest.java | 2 +- .../extensions/sketching/TDigestQuantilesTest.java | 2 +- .../beam/sdk/extensions/sorter/SortValuesTest.java | 2 +- .../sdk/extensions/sql/jdbc/BeamSqlLineIT.java | 2 +- .../sdk/extensions/sql/jdbc/BeamSqlLineTest.java | 2 +- .../sql/BeamSqlDslSqlStdOperatorsTest.java | 2 +- .../sdk/extensions/sql/impl/JdbcDriverTest.java | 2 +- .../provider/kafka/BeamKafkaTableProtoTest.java | 2 +- .../meta/provider/text/TextTableProviderTest.java | 2 +- .../sql/meta/store/InMemoryMetaStoreTest.java | 2 +- .../org/apache/beam/sdk/fn/IdGeneratorsTest.java | 2 +- .../sdk/fn/channel/SocketAddressFactoryTest.java | 2 +- .../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 2 +- ...DataSizeBasedBufferingOutboundObserverTest.java | 2 +- .../CompletableFutureInboundDataClientTest.java | 2 +- .../beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 2 +- .../beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 2 +- .../fn/splittabledofn/RestrictionTrackersTest.java | 2 +- .../beam/sdk/fn/stream/AdvancingPhaserTest.java | 2 +- .../apache/beam/sdk/fn/stream/DataStreamsTest.java | 2 +- .../sdk/fn/stream/OutboundObserverFactoryTest.java | 2 +- .../apache/beam/sdk/fn/test/TestStreamsTest.java | 2 +- .../beam/fn/harness/AssignWindowsRunnerTest.java | 2 +- .../beam/fn/harness/BeamFnDataReadRunnerTest.java | 2 +- .../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 2 +- .../apache/beam/fn/harness/CombineRunnersTest.java | 2 +- .../apache/beam/fn/harness/FlattenRunnerTest.java | 2 +- .../beam/fn/harness/FnApiDoFnRunnerTest.java | 2 +- .../apache/beam/fn/harness/MapFnRunnersTest.java | 2 +- .../fn/harness/PrecombineGroupingTableTest.java | 2 +- .../beam/fn/harness/WindowMergingFnRunnerTest.java | 2 +- .../harness/control/BeamFnControlClientTest.java | 2 +- .../harness/control/BundleSplitListenerTest.java | 2 +- .../harness/control/ProcessBundleHandlerTest.java | 2 +- .../fn/harness/data/BeamFnDataGrpcClientTest.java | 2 +- .../data/BeamFnDataInboundObserverTest.java | 2 +- .../data/PCollectionConsumerRegistryTest.java | 2 +- .../harness/data/QueueingBeamFnDataClientTest.java | 2 +- .../harness/logging/BeamFnLoggingClientTest.java | 2 +- .../state/BeamFnStateGrpcClientCacheTest.java | 2 +- .../stream/HarnessStreamObserverFactoriesTest.java | 2 +- .../beam/sdk/io/aws/coders/AwsCodersTest.java | 2 +- .../beam/sdk/io/aws/options/AwsModuleTest.java | 2 +- .../beam/sdk/io/aws/s3/S3FileSystemTest.java | 2 +- .../sdk/io/aws/sns/PublishResultCodersTest.java | 2 +- .../beam/sdk/io/aws2/options/AwsModuleTest.java | 2 +- .../blobstore/AzureBlobStoreFileSystemTest.java | 2 +- .../beam/sdk/io/cassandra/CassandraIOTest.java | 2 +- .../io/contextualtextio/ContextualTextIOTest.java | 2 +- .../elasticsearch/ElasticsearchIOTestCommon.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 2 +- .../io/gcp/bigquery/BigQueryServicesImplTest.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 2 +- .../sdk/io/gcp/bigquery/TableRowJsonCoderTest.java | 2 +- .../sdk/io/gcp/bigtable/BigtableConfigTest.java | 2 +- .../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 2 +- .../beam/sdk/io/gcp/bigtable/BigtableWriteIT.java | 2 +- .../io/gcp/datastore/AdaptiveThrottlerTest.java | 2 +- .../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 2 +- .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 2 +- .../pubsub/PubsubMessagePayloadOnlyCoderTest.java | 2 +- ...MessageWithAttributesAndMessageIdCoderTest.java | 2 +- .../PubsubMessageWithAttributesCoderTest.java | 2 +- .../PubsubMessageWithMessageIdCoderTest.java | 2 +- .../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 2 +- .../io/gcp/spanner/MutationSizeEstimatorTest.java | 2 +- .../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 2 +- .../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 2 +- .../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 2 +- .../beam/sdk/io/gcp/spanner/StructUtilsTest.java | 2 +- .../beam/sdk/io/hadoop/WritableCoderTest.java | 2 +- .../sdk/io/hdfs/HadoopFileSystemModuleTest.java | 2 +- .../hdfs/HadoopFileSystemOptionsRegistrarTest.java | 2 +- .../sdk/io/hdfs/HadoopFileSystemOptionsTest.java | 2 +- .../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 2 +- .../io/hadoop/format/HadoopFormatIOReadTest.java | 2 +- .../org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 2 +- .../beam/sdk/io/hcatalog/HCatalogIOTest.java | 2 +- .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 2 +- .../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 2 +- .../CustomTimestampPolicyWithLimitedDelayTest.java | 2 +- .../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 2 +- .../java/org/apache/beam/sdk/io/kudu/KuduIOIT.java | 4 ++-- .../apache/beam/sdk/io/parquet/ParquetIOTest.java | 4 ++-- .../beam/sdk/io/solr/JavaBinCodecCoderTest.java | 2 +- .../apache/beam/sdk/io/tika/ParseResultTest.java | 2 +- .../org/apache/beam/sdk/io/tika/TikaIOTest.java | 2 +- .../org/apache/beam/sdk/io/xml/JAXBCoderTest.java | 2 +- .../java/org/apache/beam/sdk/io/xml/XmlIOTest.java | 11 +++++----- .../org/apache/beam/sdk/io/xml/XmlSourceTest.java | 2 +- .../sdk/nexmark/queries/NexmarkQueryModel.java | 4 +++- .../beam/sdk/nexmark/NexmarkConfigurationTest.java | 2 +- .../beam/sdk/nexmark/PerfsToBigQueryTest.java | 2 +- .../nexmark/queries/BoundedSideInputJoinTest.java | 2 +- .../nexmark/queries/SessionSideInputJoinTest.java | 2 +- .../queries/sql/SqlBoundedSideInputJoinTest.java | 2 +- 468 files changed, 532 insertions(+), 510 deletions(-)