You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2025/02/25 11:27:58 UTC
(flink) branch master updated (25f0cf306c6 -> e8354665a28)
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 25f0cf306c6 [FLINK-37162][docs] Add sinks.md to describe Flink's Data Sink API
add e8019511a80 [FLINK-37376] Upgrade to flink-shaded 20.0
add e8354665a28 [FLINK-37377] Upgrade guava to 33.4.0
No new revisions were added by this update.
Summary of changes:
.../archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 4 ++--
.../flink/client/program/StreamContextEnvironment.java | 4 ++--
.../apache/flink/client/program/rest/UrlPrefixDecorator.java | 2 +-
.../client/deployment/application/JarManifestParserTest.java | 4 ++--
.../flink/client/program/PerJobMiniClusterFactoryTest.java | 2 +-
.../apache/flink/client/testjar/ForbidConfigurationJob.java | 2 +-
.../connector/file/table/stream/AbstractStreamingWriter.java | 2 +-
.../connector/file/table/FileSystemOutputFormatTest.java | 2 +-
.../org/apache/flink/api/common/io/OutputFormatBase.java | 2 +-
.../io/ratelimiting/GuavaFlinkConnectorRateLimiter.java | 2 +-
.../connector/source/util/ratelimit/GuavaRateLimiter.java | 2 +-
.../api/java/typeutils/runtime/JavaRecordBuilderFactory.java | 2 +-
.../java/org/apache/flink/configuration/CleanupOptions.java | 2 +-
.../java/org/apache/flink/configuration/CoreOptions.java | 2 +-
.../apache/flink/configuration/description/TextElement.java | 2 +-
.../apache/flink/core/classloading/ComponentClassLoader.java | 2 +-
.../java/org/apache/flink/core/fs/AutoCloseableRegistry.java | 2 +-
.../java/org/apache/flink/core/fs/CloseableRegistry.java | 2 +-
.../src/main/java/org/apache/flink/core/fs/FileSystem.java | 8 ++++----
.../org/apache/flink/core/plugin/DefaultPluginManager.java | 4 ++--
.../src/main/java/org/apache/flink/util/FileUtils.java | 4 ++--
flink-core/src/main/java/org/apache/flink/util/NetUtils.java | 2 +-
.../flink/core/io/SimpleVersionedSerializationTest.java | 2 +-
.../java/org/apache/flink/core/plugin/PluginConfigTest.java | 2 +-
.../test/java/org/apache/flink/dist/BashJavaUtilsITCase.java | 2 +-
.../flink/changelog/fs/AbstractStateChangeFsUploader.java | 2 +-
.../flink/changelog/fs/FsStateChangelogWriterTest.java | 2 +-
.../streaming/tests/queryablestate/QsStateProducer.java | 2 +-
.../java/org/apache/flink/fs/gs/utils/ChecksumUtils.java | 4 ++--
.../apache/flink/fs/gs/writer/GSChecksumWriteChannel.java | 2 +-
.../org/apache/flink/fs/gs/utils/ConfigUtilsHadoopTest.java | 4 ++--
.../flink/fs/s3/common/HAJobRunOnMinioS3StoreITCase.java | 4 ++--
.../org/apache/flink/formats/csv/CsvFormatFactoryTest.java | 4 ++--
.../apache/flink/formats/csv/CsvRowDataSerDeSchemaTest.java | 4 ++--
.../flink/formats/parquet/vector/ParquetSplitReaderUtil.java | 2 +-
.../flink/formats/parquet/vector/type/ParquetGroupField.java | 2 +-
.../parquet/vector/ParquetColumnarRowSplitReaderTest.java | 2 +-
.../flink/formats/protobuf/util/PbCodegenAppender.java | 2 +-
.../kubeclient/decorators/FlinkConfMountDecorator.java | 2 +-
.../kubeclient/decorators/KerberosMountDecorator.java | 2 +-
.../kubeclient/decorators/PodTemplateMountDecorator.java | 2 +-
.../org/apache/flink/kubernetes/KubernetesTestUtils.java | 2 +-
.../kubeclient/resources/KubernetesSharedInformerITCase.java | 2 +-
.../org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java | 10 +++++-----
.../java/org/apache/flink/cep/nfa/AfterMatchSkipITCase.java | 2 +-
.../src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java | 2 +-
.../src/test/java/org/apache/flink/cep/nfa/GroupITCase.java | 2 +-
.../org/apache/flink/cep/nfa/IterativeConditionsITCase.java | 2 +-
.../src/test/java/org/apache/flink/cep/nfa/NFAITCase.java | 2 +-
.../test/java/org/apache/flink/cep/nfa/NotPatternITCase.java | 2 +-
.../java/org/apache/flink/cep/nfa/SameElementITCase.java | 4 ++--
.../java/org/apache/flink/cep/nfa/TimesOrMoreITCase.java | 2 +-
.../test/java/org/apache/flink/cep/nfa/TimesRangeITCase.java | 2 +-
.../java/org/apache/flink/cep/nfa/UntilConditionITCase.java | 2 +-
.../org/apache/flink/cep/nfa/compiler/NFACompilerTest.java | 2 +-
.../java/org/apache/flink/cep/operator/CEPOperatorTest.java | 2 +-
.../apache/flink/state/api/runtime/OperatorIDGenerator.java | 2 +-
.../java/org/apache/flink/state/table/KeyedStateReader.java | 4 ++--
.../flink/metrics/otel/OpenTelemetryMetricAdapterTest.java | 2 +-
.../java/org/apache/flink/client/python/PythonEnvUtils.java | 2 +-
.../apache/flink/client/python/PythonFunctionFactory.java | 8 ++++----
.../flink/python/chain/PythonOperatorChainingOptimizer.java | 6 +++---
.../flink/python/env/AbstractPythonEnvironmentManager.java | 2 +-
.../java/org/apache/flink/python/util/PythonConfigUtil.java | 6 +++---
.../apache/flink/streaming/api/utils/PythonTypeUtils.java | 2 +-
.../org/apache/flink/table/runtime/arrow/ArrowUtils.java | 2 +-
.../org/apache/flink/table/runtime/arrow/ArrowUtilsTest.java | 2 +-
.../runtime/arrow/sources/ArrowSourceFunctionTestBase.java | 2 +-
.../flink/queryablestate/network/AbstractServerBase.java | 2 +-
.../java/org/apache/flink/queryablestate/network/Client.java | 2 +-
.../flink/runtime/webmonitor/handlers/JarRunHandler.java | 2 +-
.../runtime/webmonitor/handlers/utils/JarHandlerUtils.java | 2 +-
.../operators/windowing/AsyncEvictingWindowOperator.java | 4 ++--
.../org/apache/flink/runtime/blob/FileSystemBlobStore.java | 2 +-
.../apache/flink/runtime/checkpoint/TaskStateSnapshot.java | 2 +-
.../flink/runtime/clusterframework/ApplicationStatus.java | 4 ++--
.../flink/runtime/clusterframework/BootstrapTools.java | 4 ++--
.../runtime/dispatcher/ConfigurationNotAllowedMessage.java | 2 +-
.../runtime/dispatcher/FileExecutionGraphInfoStore.java | 12 ++++++------
.../runtime/dispatcher/MemoryExecutionGraphInfoStore.java | 6 +++---
.../flink/runtime/entrypoint/SessionClusterEntrypoint.java | 2 +-
.../apache/flink/runtime/executiongraph/JobInformation.java | 4 ++--
.../flink/runtime/io/network/api/TaskEventHandler.java | 4 ++--
.../apache/flink/runtime/io/network/netty/NettyServer.java | 2 +-
.../runtime/io/network/partition/PipelinedSubpartition.java | 2 +-
.../io/network/partition/UnionResultSubpartitionView.java | 4 ++--
.../io/network/partition/consumer/RemoteInputChannel.java | 2 +-
.../io/network/partition/consumer/UnionInputGate.java | 2 +-
.../network/partition/hybrid/index/FileDataIndexCache.java | 6 +++---
.../tiered/file/ProducerMergedPartitionFileWriter.java | 2 +-
.../hybrid/tiered/file/SegmentPartitionFileWriter.java | 2 +-
.../tiered/storage/TieredStorageMemoryManagerImpl.java | 2 +-
.../java/org/apache/flink/runtime/metrics/ReporterSetup.java | 2 +-
.../apache/flink/runtime/rest/handler/AbstractHandler.java | 2 +-
.../runtime/rest/handler/async/CompletedOperationCache.java | 8 ++++----
.../handler/job/checkpoints/AbstractCheckpointHandler.java | 2 +-
.../job/checkpoints/AbstractCheckpointStatsHandler.java | 2 +-
.../job/checkpoints/CheckpointStatisticDetailsHandler.java | 2 +-
.../rest/handler/job/checkpoints/CheckpointStatsCache.java | 4 ++--
.../job/checkpoints/CheckpointingStatisticsHandler.java | 2 +-
.../checkpoints/TaskCheckpointStatisticDetailsHandler.java | 2 +-
.../handler/taskmanager/AbstractTaskManagerFileHandler.java | 8 ++++----
.../runtime/scheduler/adaptive/JobGraphJobInformation.java | 2 +-
.../adaptivebatch/DefaultBatchJobRecoveryHandler.java | 2 +-
.../runtime/source/coordinator/SourceCoordinatorContext.java | 2 +-
.../main/java/org/apache/flink/runtime/state/StateUtil.java | 2 +-
.../runtime/state/changelog/StateChangelogStorageLoader.java | 2 +-
.../org/apache/flink/runtime/taskexecutor/TaskExecutor.java | 4 ++--
.../taskexecutor/TaskExecutorMemoryConfiguration.java | 2 +-
.../org/apache/flink/runtime/util/DefaultGroupCache.java | 8 ++++----
.../flink/runtime/util/config/memory/ManagedMemoryUtils.java | 4 ++--
.../apache/flink/runtime/webmonitor/WebMonitorEndpoint.java | 4 ++--
.../webmonitor/stats/TaskStatsRequestCoordinator.java | 4 ++--
.../webmonitor/threadinfo/ThreadInfoRequestCoordinator.java | 2 +-
.../webmonitor/threadinfo/VertexThreadInfoTracker.java | 4 ++--
.../threadinfo/VertexThreadInfoTrackerBuilder.java | 4 ++--
.../flink/streaming/api/graph/StreamGraphHasherV2.java | 6 +++---
.../streaming/api/operators/OperatorSnapshotFutures.java | 2 +-
.../streaming/api/operators/StreamOperatorStateHandler.java | 2 +-
.../streaming/api/transformations/CacheTransformation.java | 2 +-
.../api/transformations/GlobalCommitterTransform.java | 2 +-
.../api/transformations/LegacySinkTransformation.java | 2 +-
.../api/transformations/OneInputTransformation.java | 2 +-
.../api/transformations/PartitionTransformation.java | 2 +-
.../streaming/api/transformations/ReduceTransformation.java | 2 +-
.../api/transformations/SideOutputTransformation.java | 2 +-
.../streaming/api/transformations/SinkTransformation.java | 2 +-
.../api/transformations/SourceTransformationWrapper.java | 2 +-
.../TimestampsAndWatermarksTransformation.java | 2 +-
.../streaming/api/transformations/UnionTransformation.java | 2 +-
.../io/recovery/DemultiplexingRecordDeserializer.java | 2 +-
.../runtime/io/recovery/RescalingStreamTaskNetworkInput.java | 2 +-
.../streaming/runtime/operators/sink/SinkWriterOperator.java | 2 +-
.../operators/sink/StatefulSinkWriterStateHandler.java | 2 +-
.../sink/committables/SubtaskCommittableManager.java | 2 +-
.../runtime/operators/windowing/EvictingWindowOperator.java | 6 +++---
.../apache/flink/streaming/runtime/tasks/OperatorChain.java | 2 +-
.../operators/AsyncIntervalJoinOperatorTest.java | 4 ++--
.../checkpoint/CheckpointCoordinatorRestoringTest.java | 2 +-
.../flink/runtime/checkpoint/CheckpointCoordinatorTest.java | 2 +-
.../checkpoint/DefaultCheckpointStatsTrackerTest.java | 2 +-
.../checkpoint/InflightDataRescalingDescriptorUtil.java | 2 +-
.../checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java | 2 +-
.../checkpoint/channel/RecordingChannelStateWriter.java | 4 ++--
.../channel/SequentialChannelStateReaderImplTest.java | 2 +-
.../org/apache/flink/runtime/dispatcher/DispatcherTest.java | 2 +-
.../runtime/dispatcher/ExecutionGraphInfoStoreTestUtils.java | 2 +-
.../runtime/dispatcher/FileExecutionGraphInfoStoreTest.java | 4 ++--
.../org/apache/flink/runtime/dispatcher/JobMasterTester.java | 2 +-
.../dispatcher/MemoryExecutionGraphInfoStoreTest.java | 2 +-
.../DefaultExecutionGraphConstructionTest.java | 2 +-
.../executiongraph/utils/TestFailoverStrategyFactory.java | 2 +-
.../flink/runtime/filecache/FileCacheReadsFromBlobTest.java | 2 +-
.../network/partition/JobMasterPartitionTrackerImplTest.java | 2 +-
.../partition/TaskExecutorPartitionTrackerImplTest.java | 2 +-
.../io/network/partition/consumer/LocalInputChannelTest.java | 2 +-
.../network/partition/consumer/RemoteInputChannelTest.java | 2 +-
.../io/network/partition/consumer/SingleInputGateTest.java | 2 +-
.../runtime/io/network/util/TestPooledBufferProvider.java | 2 +-
.../jobgraph/topology/DefaultLogicalTopologyTest.java | 2 +-
.../jobmaster/DefaultJobMasterServiceProcessTest.java | 2 +-
.../jobmaster/slotpool/BlocklistDeclarativeSlotPoolTest.java | 2 +-
.../jobmaster/slotpool/DeclarativeSlotPoolServiceTest.java | 2 +-
.../jobmaster/slotpool/DefaultAllocatedSlotPoolTest.java | 2 +-
.../jobmaster/slotpool/DefaultDeclarativeSlotPoolTest.java | 2 +-
.../slotpool/SimpleRequestSlotMatchingStrategyTest.java | 2 +-
.../leaderelection/ZooKeeperLeaderElectionDriverTest.java | 2 +-
.../apache/flink/runtime/metrics/MetricRegistryImplTest.java | 2 +-
.../flink/runtime/metrics/groups/FrontMetricGroupTest.java | 2 +-
.../apache/flink/runtime/metrics/util/MetricUtilsTest.java | 2 +-
.../coordination/CoordinatorEventsExactlyOnceITCase.java | 2 +-
.../runtime/operators/hash/InPlaceMutableHashTableTest.java | 2 +-
.../resourcemanager/active/ActiveResourceManagerTest.java | 2 +-
.../job/checkpoints/AbstractCheckpointStatsHandlerTest.java | 4 ++--
.../runtime/scheduler/AbstractSlotSharingStrategyTest.java | 2 +-
.../scheduler/AvailableInputsLocationsRetrieverTest.java | 2 +-
.../apache/flink/runtime/scheduler/DefaultSchedulerTest.java | 2 +-
.../flink/runtime/scheduler/ExecutionGraphInfoTest.java | 2 +-
.../LocalInputPreferredSlotSharingStrategyTest.java | 4 ++--
.../TaskBalancedPreferredSlotSharingStrategyTest.java | 4 ++--
.../scheduler/adapter/DefaultExecutionTopologyTest.java | 2 +-
.../adapter/DefaultSchedulingPipelinedRegionTest.java | 2 +-
.../scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java | 2 +-
.../DefaultVertexParallelismAndInputInfosDeciderTest.java | 2 +-
.../scheduler/adaptivebatch/SpeculativeExecutionTest.java | 4 ++--
.../exceptionhistory/FailureHandlingResultSnapshotTest.java | 2 +-
.../exceptionhistory/RootExceptionHistoryEntryTest.java | 2 +-
.../org/apache/flink/runtime/security/SecurityUtilsTest.java | 2 +-
.../apache/flink/runtime/shuffle/NettyShuffleUtilsTest.java | 2 +-
.../flink/runtime/state/InternalPriorityQueueTestBase.java | 2 +-
.../org/apache/flink/runtime/state/StateBackendTestBase.java | 2 +-
.../state/TaskExecutorLocalStateStoresManagerTest.java | 2 +-
.../runtime/state/ttl/TtlMapStateAllEntriesTestContext.java | 2 +-
.../apache/flink/runtime/taskexecutor/TaskExecutorTest.java | 2 +-
.../taskexecutor/TaskManagerRunnerConfigurationTest.java | 2 +-
.../runtime/taskexecutor/TaskManagerRunnerStartupTest.java | 2 +-
.../FileSlotAllocationSnapshotPersistenceServiceTest.java | 2 +-
.../runtime/taskexecutor/slot/TaskSlotTableImplTest.java | 2 +-
.../org/apache/flink/runtime/util/DefaultGroupCacheTest.java | 2 +-
.../java/org/apache/flink/runtime/util/ManualTicker.java | 2 +-
.../org/apache/flink/runtime/util/ResourceCounterTest.java | 2 +-
.../java/org/apache/flink/runtime/util/RunnablesTest.java | 2 +-
.../flink/runtime/util/ZooKeeperUtilsTreeCacheTest.java | 2 +-
.../threadinfo/ThreadInfoRequestCoordinatorTest.java | 2 +-
.../webmonitor/threadinfo/VertexThreadInfoTrackerTest.java | 10 +++++-----
.../runtime/zookeeper/ZooKeeperStateHandleStoreTest.java | 2 +-
.../apache/flink/streaming/api/AggregationFunctionTest.java | 2 +-
.../streaming/api/operators/co/IntervalJoinOperatorTest.java | 4 ++--
.../runtime/io/checkpointing/CheckpointedInputGateTest.java | 2 +-
.../io/recovery/DemultiplexingRecordDeserializerTest.java | 2 +-
.../runtime/operators/windowing/CountTriggerTest.java | 2 +-
.../runtime/operators/windowing/EventTimeTriggerTest.java | 2 +-
.../operators/windowing/ProcessingTimeTriggerTest.java | 2 +-
.../flink/state/changelog/ChangelogKeyedStateBackend.java | 2 +-
.../state/common/PeriodicMaterializationManagerTest.java | 2 +-
.../flink/state/forst/ForStIncrementalCheckpointUtils.java | 2 +-
.../state/forst/sync/ForStDBCachingPriorityQueueSet.java | 2 +-
.../flink/state/rocksdb/RocksDBCachingPriorityQueueSet.java | 2 +-
.../state/rocksdb/RocksDBIncrementalCheckpointUtils.java | 2 +-
.../flink/state/rocksdb/sstmerge/CompactionScheduler.java | 2 +-
.../flink/state/rocksdb/sstmerge/CompactionTaskProducer.java | 2 +-
.../flink/streaming/api/windowing/evictors/DeltaEvictor.java | 2 +-
.../flink/streaming/api/graph/AdaptiveGraphManagerTest.java | 2 +-
.../flink/streaming/api/graph/JobGraphGeneratorTestBase.java | 2 +-
.../streaming/api/graph/StreamingJobGraphGeneratorTest.java | 2 +-
.../streaming/api/operators/async/AsyncWaitOperatorTest.java | 2 +-
.../runtime/operators/sink/SinkV2SinkWriterOperatorTest.java | 2 +-
.../flink/streaming/runtime/operators/sink/TestSinkV2.java | 2 +-
.../operators/windowing/ContinuousEventTimeTriggerTest.java | 2 +-
.../runtime/operators/windowing/MergingWindowSetTest.java | 2 +-
.../windowing/ProcessingTimeSessionWindowsTest.java | 2 +-
.../runtime/operators/windowing/WindowOperatorTest.java | 4 ++--
.../streaming/runtime/tasks/SourceStreamTaskTestBase.java | 2 +-
.../runtime/tasks/SubtaskCheckpointCoordinatorTest.java | 2 +-
.../org/apache/flink/table/client/cli/CliClientITCase.java | 2 +-
.../table/client/cli/CliClientMultiStatementITTest.java | 2 +-
.../table/gateway/service/operation/OperationManager.java | 2 +-
.../gateway/service/SqlGatewayServiceStatementITCase.java | 2 +-
.../flink/table/gateway/service/utils/MockHttpServer.java | 2 +-
.../connector/datagen/table/SequenceGeneratorVisitor.java | 2 +-
.../apache/flink/table/api/config/LookupJoinHintOptions.java | 2 +-
.../apache/flink/table/api/internal/PlanCacheManager.java | 6 +++---
.../org/apache/flink/table/resource/ResourceManager.java | 2 +-
.../flink/table/api/typeutils/TraversableSerializer.scala | 2 +-
.../connector/source/lookup/cache/DefaultLookupCache.java | 6 +++---
.../table/functions/LegacyUserDefinedFunctionInference.java | 2 +-
.../flink/table/types/extraction/ExtractionUtilsTest.java | 2 +-
.../table/planner/analyze/FlinkStreamPlanAnalyzers.java | 2 +-
.../apache/flink/table/planner/calcite/FlinkRelBuilder.java | 2 +-
.../apache/flink/table/planner/calcite/FlinkRexBuilder.java | 2 +-
.../planner/functions/sql/SqlCumulateTableFunction.java | 2 +-
.../planner/functions/sql/SqlFirstLastValueAggFunction.java | 2 +-
.../table/planner/functions/sql/SqlHopTableFunction.java | 2 +-
.../table/planner/functions/sql/SqlListAggFunction.java | 2 +-
.../table/planner/functions/sql/SqlSessionTableFunction.java | 4 ++--
.../table/planner/functions/sql/SqlTumbleTableFunction.java | 2 +-
.../table/planner/functions/sql/SqlWindowTableFunction.java | 2 +-
.../apache/flink/table/planner/hint/FlinkHintStrategies.java | 2 +-
.../table/planner/plan/nodes/exec/serde/JsonPlanGraph.java | 2 +-
.../plan/nodes/exec/stream/StreamExecIntervalJoin.java | 2 +-
.../table/planner/plan/nodes/exec/stream/StreamExecJoin.java | 2 +-
.../planner/plan/nodes/exec/stream/StreamExecWindowJoin.java | 2 +-
.../plan/rules/logical/FlinkAggregateJoinTransposeRule.java | 2 +-
.../rules/logical/FlinkSemiAntiJoinFilterTransposeRule.java | 2 +-
.../table/planner/plan/rules/logical/LogicalUnnestRule.java | 2 +-
.../planner/plan/rules/logical/WindowPropertiesRules.java | 4 ++--
.../table/planner/plan/schema/FlinkPreparingTableBase.java | 6 +++---
.../table/planner/plan/utils/RelDescriptionWriterImpl.java | 2 +-
.../java/org/apache/flink/table/planner/utils/Expander.java | 2 +-
.../flink-table-planner/src/main/resources/META-INF/NOTICE | 2 +-
.../table/planner/plan/schema/LegacyTableSourceTable.scala | 2 +-
.../flink/table/planner/catalog/CatalogConstraintTest.java | 2 +-
.../flink/table/planner/functions/JsonFunctionsITCase.java | 10 ++--------
.../SqlMaterializedTableNodeToOperationConverterTest.java | 2 +-
.../plan/nodes/exec/serde/AggregateCallSerdeTest.java | 2 +-
.../plan/nodes/exec/testutils/RestoreTestCompleteness.java | 2 +-
.../java/org/apache/flink/formats/raw/RawFormatFactory.java | 2 +-
.../apache/flink/table/runtime/functions/JsonPathCache.java | 4 ++--
.../functions/table/lookup/fullcache/CacheLoader.java | 2 +-
.../apache/flink/table/runtime/generated/CompileUtils.java | 4 ++--
.../operators/rank/TopNBufferCacheRemovalListener.java | 6 +++---
.../table/runtime/operators/rank/UpdatableTopNFunction.java | 4 ++--
.../runtime/operators/rank/utils/AppendOnlyTopNHelper.java | 4 ++--
.../table/runtime/operators/rank/utils/FastTop1Helper.java | 4 ++--
.../operators/window/tvf/slicing/SliceAssignerTestBase.java | 2 +-
flink-table/pom.xml | 2 +-
.../flink/connector/testframe/container/FlinkContainers.java | 2 +-
.../testframe/utils/UnorderedCollectIteratorAssert.java | 2 +-
.../file/testutils/catalog/TestFileSystemCatalogITCase.java | 2 +-
.../test/checkpointing/ChangelogRecoveryITCaseBase.java | 2 +-
.../checkpointing/UdfStreamOperatorCheckpointingITCase.java | 2 +-
.../flink/test/checkpointing/UnalignedCheckpointITCase.java | 2 +-
.../test/checkpointing/UnalignedCheckpointStressITCase.java | 2 +-
.../test/checkpointing/UnalignedCheckpointTestBase.java | 4 ++--
.../test/checkpointing/utils/CancellingIntegerSource.java | 2 +-
.../apache/flink/test/plugin/DefaultPluginManagerTest.java | 2 +-
.../apache/flink/test/recovery/ClusterEntrypointITCase.java | 2 +-
.../apache/flink/test/recovery/TaskManagerRunnerITCase.java | 2 +-
.../runtime/KeyedPartitionWindowedStreamITCase.java | 2 +-
.../runtime/NonKeyedPartitionWindowedStreamITCase.java | 2 +-
.../flink/test/streaming/runtime/SinkV2MetricsITCase.java | 2 +-
.../org/apache/flink/yarn/YARNHighAvailabilityITCase.java | 2 +-
.../flink/yarn/YARNSessionCapacitySchedulerITCase.java | 2 +-
.../org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java | 2 +-
.../org/apache/flink/yarn/testjob/YarnTestArchiveJob.java | 2 +-
.../java/org/apache/flink/yarn/testjob/YarnTestCacheJob.java | 2 +-
.../apache/flink/yarn/YarnApplicationFileUploaderTest.java | 2 +-
.../test/java/org/apache/flink/yarn/YarnFileStageTest.java | 2 +-
.../org/apache/flink/yarn/YarnResourceManagerDriverTest.java | 2 +-
pom.xml | 8 ++++----
310 files changed, 404 insertions(+), 410 deletions(-)