You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ib...@apache.org on 2021/01/06 18:37:32 UTC
[beam] branch master updated (b2ad4dd -> 60834ae)
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(-)