This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0d3be65c06b [hotfix][test] Adds back timestamp to log output
add 15361471676 [FLINK-14068][core] Removes deprecated
org.apache.flink.api.common.time.Time (#25250)
No new revisions were added by this update.
Summary of changes:
.../docs/dev/datastream/fault-tolerance/state.md | 16 +-
.../docs/ops/state/task_failure_recovery.md | 14 +-
.../docs/dev/datastream/fault-tolerance/state.md | 18 +--
.../docs/ops/state/task_failure_recovery.md | 14 +-
.../ApplicationDispatcherBootstrap.java | 8 +-
.../deployment/application/EmbeddedJobClient.java | 8 +-
.../application/JobStatusPollingUtils.java | 8 +-
.../application/executors/EmbeddedExecutor.java | 7 +-
.../executors/EmbeddedExecutorFactory.java | 6 +-
.../client/program/rest/RestClusterClient.java | 3 +-
.../connector/base/sink/AsyncSinkBaseITCase.java | 5 +-
.../file/sink/BatchExecutionFileSinkITCase.java | 5 +-
.../sink/StreamingExecutionFileSinkITCase.java | 4 +-
.../file/sink/writer/FileWriterBucketTest.java | 6 +-
.../wikiedits/WikipediaEditsSourceTest.java | 8 +-
.../common/restartstrategy/RestartStrategies.java | 134 +---------------
.../flink/api/common/state/StateTtlConfig.java | 33 ----
.../org/apache/flink/api/common/time/Time.java | 172 ---------------------
.../flink/configuration/ConfigurationUtils.java | 14 +-
.../main/java/org/apache/flink/util/TimeUtils.java | 38 +----
.../flink/api/common/ExecutionConfigTest.java | 4 +-
.../eventtime/WatermarksWithIdlenessTest.java | 2 +-
.../api/common/state/StateDescriptorTest.java | 4 +-
.../flink/api/common/state/StateTtlConfigTest.java | 10 +-
.../org/apache/flink/testutils/TestingUtils.java | 7 +-
.../flink/util/TimeUtilsPrettyPrintingTest.java | 3 +-
.../java/org/apache/flink/util/TimeUtilsTest.java | 11 --
.../flink/connector/file/sink/FileSinkProgram.java | 6 +-
.../flink/sql/tests/StreamSQLTestProgram.java | 6 +-
.../flink/streaming/tests/TtlTestConfig.java | 11 +-
.../tests/verify/AbstractTtlStateVerifier.java | 2 +-
...HighAvailabilityRecoverFromSavepointITCase.java | 2 +-
flink-python/pyflink/common/restart_strategy.py | 16 +-
.../datastream/connectors/tests/test_kafka.py | 2 +
.../pyflink/fn_execution/embedded/java_utils.py | 4 +-
flink-python/pyflink/table/table_config.py | 6 +-
flink-python/pyflink/util/java_utils.py | 16 +-
.../org/apache/flink/python/util/ProtoUtils.java | 4 +-
.../flink/streaming/api/utils/ProtoUtilsTest.java | 6 +-
.../flink/runtime/rpc/pekko/PekkoRpcActorTest.java | 9 +-
.../runtime/rpc/pekko/TimeoutCallStackTest.java | 11 +-
.../apache/flink/runtime/rpc/RpcGatewayUtils.java | 8 +-
.../org/apache/flink/runtime/rpc/RpcUtils.java | 3 +-
.../runtime/webmonitor/WebSubmissionExtension.java | 6 +-
.../webmonitor/handlers/JarDeleteHandler.java | 4 +-
.../webmonitor/handlers/JarListHandler.java | 4 +-
.../webmonitor/handlers/JarPlanHandler.java | 6 +-
.../runtime/webmonitor/handlers/JarRunHandler.java | 4 +-
.../webmonitor/handlers/JarUploadHandler.java | 4 +-
.../webmonitor/LeaderRetrievalHandlerTest.java | 17 +-
.../runtime/webmonitor/WebMonitorUtilsTest.java | 4 +-
.../webmonitor/WebSubmissionExtensionTest.java | 5 +-
.../webmonitor/handlers/JarDeleteHandlerTest.java | 4 +-
.../handlers/JarHandlerParameterTest.java | 6 +-
.../runtime/webmonitor/handlers/JarHandlers.java | 4 +-
.../handlers/JarRunHandlerParameterTest.java | 3 +-
.../webmonitor/handlers/JarUploadHandlerTest.java | 4 +-
.../flink/runtime/dispatcher/Dispatcher.java | 54 +++----
.../DispatcherCachedOperationsHandler.java | 10 +-
.../runtime/dispatcher/DispatcherGateway.java | 16 +-
.../runtime/dispatcher/DispatcherRestEndpoint.java | 6 +-
.../dispatcher/FileExecutionGraphInfoStore.java | 12 +-
.../dispatcher/MemoryExecutionGraphInfoStore.java | 12 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 8 +-
.../dispatcher/TriggerCheckpointFunction.java | 4 +-
.../dispatcher/TriggerSavepointFunction.java | 4 +-
.../cleanup/CheckpointResourcesCleanupRunner.java | 10 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 8 +-
.../entrypoint/SessionClusterEntrypoint.java | 6 +-
.../executiongraph/DefaultExecutionGraph.java | 6 +-
.../DefaultExecutionGraphBuilder.java | 4 +-
.../flink/runtime/executiongraph/Execution.java | 6 +-
.../runtime/executiongraph/ExecutionJobVertex.java | 6 +-
.../runtime/executiongraph/ExecutionVertex.java | 6 +-
.../SpeculativeExecutionJobVertex.java | 5 +-
.../executiongraph/SpeculativeExecutionVertex.java | 4 +-
.../jobmanager/slots/TaskManagerGateway.java | 13 +-
.../DefaultSlotPoolServiceSchedulerFactory.java | 5 +-
.../flink/runtime/jobmaster/JobManagerRunner.java | 10 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 27 ++--
.../runtime/jobmaster/JobMasterConfiguration.java | 22 +--
.../flink/runtime/jobmaster/JobMasterGateway.java | 23 ++-
.../JobMasterServiceLeadershipRunner.java | 10 +-
.../runtime/jobmaster/RpcTaskManagerGateway.java | 11 +-
.../jobmaster/SlotPoolServiceSchedulerFactory.java | 6 +-
.../slotpool/DefaultDeclarativeSlotPool.java | 6 +-
.../slotpool/PhysicalSlotRequestBulkChecker.java | 5 +-
.../PhysicalSlotRequestBulkCheckerImpl.java | 15 +-
.../flink/runtime/metrics/MetricRegistryImpl.java | 7 +-
.../runtime/metrics/dump/MetricQueryService.java | 9 +-
.../flink/runtime/metrics/util/MetricUtils.java | 6 +-
.../metrics/util/SystemResourcesCounter.java | 7 +-
.../util/SystemResourcesMetricsInitializer.java | 5 +-
.../flink/runtime/minicluster/MiniCluster.java | 3 +-
.../resourcemanager/DefaultJobLeaderIdService.java | 8 +-
.../runtime/resourcemanager/ResourceManager.java | 29 ++--
.../resourcemanager/ResourceManagerGateway.java | 24 +--
...esourceManagerRuntimeServicesConfiguration.java | 13 +-
.../resourcemanager/StandaloneResourceManager.java | 10 +-
.../StandaloneResourceManagerFactory.java | 6 +-
.../active/ActiveResourceManager.java | 10 +-
.../DefaultResourceAllocationStrategy.java | 8 +-
.../slotmanager/DefaultSlotStatusSyncer.java | 6 +-
.../slotmanager/FineGrainedSlotManager.java | 5 +-
.../slotmanager/SlotManagerConfiguration.java | 20 ++-
.../org/apache/flink/runtime/rest/RestClient.java | 12 +-
.../flink/runtime/rest/RestEndpointFactory.java | 4 +-
.../flink/runtime/rest/RestServerEndpoint.java | 12 +-
.../runtime/rest/handler/AbstractHandler.java | 4 +-
.../runtime/rest/handler/AbstractRestHandler.java | 4 +-
.../rest/handler/LeaderRetrievalHandler.java | 7 +-
.../rest/handler/RestHandlerConfiguration.java | 9 +-
.../AbstractAsynchronousOperationHandlers.java | 5 +-
.../cluster/AbstractJobManagerFileHandler.java | 4 +-
.../rest/handler/cluster/ClusterConfigHandler.java | 4 +-
.../handler/cluster/ClusterOverviewHandler.java | 4 +-
.../handler/cluster/DashboardConfigHandler.java | 4 +-
.../cluster/JobManagerCustomLogHandler.java | 4 +-
.../cluster/JobManagerEnvironmentHandler.java | 4 +-
.../handler/cluster/JobManagerLogFileHandler.java | 4 +-
.../handler/cluster/JobManagerLogListHandler.java | 4 +-
.../cluster/JobManagerProfilingFileHandler.java | 4 +-
.../cluster/JobManagerProfilingHandler.java | 4 +-
.../cluster/JobManagerProfilingListHandler.java | 4 +-
.../cluster/JobManagerThreadDumpHandler.java | 4 +-
.../rest/handler/cluster/ShutdownHandler.java | 4 +-
.../dataset/ClusterDataSetDeleteHandlers.java | 5 +-
.../handler/dataset/ClusterDataSetListHandler.java | 4 +-
.../job/AbstractAccessExecutionGraphHandler.java | 4 +-
.../handler/job/AbstractExecutionGraphHandler.java | 4 +-
.../rest/handler/job/AbstractJobVertexHandler.java | 4 +-
.../handler/job/AbstractSubtaskAttemptHandler.java | 4 +-
.../rest/handler/job/AbstractSubtaskHandler.java | 4 +-
.../rest/handler/job/JobAccumulatorsHandler.java | 4 +-
.../rest/handler/job/JobCancellationHandler.java | 4 +-
.../handler/job/JobClientHeartbeatHandler.java | 4 +-
.../runtime/rest/handler/job/JobConfigHandler.java | 4 +-
.../rest/handler/job/JobDetailsHandler.java | 4 +-
.../rest/handler/job/JobExceptionsHandler.java | 4 +-
.../handler/job/JobExecutionResultHandler.java | 4 +-
.../runtime/rest/handler/job/JobIdsHandler.java | 4 +-
.../job/JobManagerJobConfigurationHandler.java | 4 +-
.../job/JobManagerJobEnvironmentHandler.java | 4 +-
.../runtime/rest/handler/job/JobPlanHandler.java | 4 +-
.../job/JobResourceRequirementsHandler.java | 4 +-
.../job/JobResourceRequirementsUpdateHandler.java | 4 +-
.../runtime/rest/handler/job/JobStatusHandler.java | 4 +-
.../runtime/rest/handler/job/JobSubmitHandler.java | 4 +-
.../handler/job/JobVertexAccumulatorsHandler.java | 4 +-
.../handler/job/JobVertexBackPressureHandler.java | 4 +-
.../rest/handler/job/JobVertexDetailsHandler.java | 4 +-
.../handler/job/JobVertexFlameGraphHandler.java | 8 +-
.../handler/job/JobVertexTaskManagersHandler.java | 4 +-
.../rest/handler/job/JobsOverviewHandler.java | 4 +-
.../job/SubtaskCurrentAttemptDetailsHandler.java | 4 +-
...SubtaskExecutionAttemptAccumulatorsHandler.java | 4 +-
.../job/SubtaskExecutionAttemptDetailsHandler.java | 4 +-
.../job/SubtasksAllAccumulatorsHandler.java | 4 +-
.../rest/handler/job/SubtasksTimesHandler.java | 4 +-
.../job/checkpoints/AbstractCheckpointHandler.java | 4 +-
.../AbstractCheckpointStatsHandler.java | 4 +-
.../job/checkpoints/CheckpointConfigHandler.java | 4 +-
.../job/checkpoints/CheckpointHandlers.java | 6 +-
.../CheckpointStatisticDetailsHandler.java | 4 +-
.../CheckpointingStatisticsHandler.java | 4 +-
.../TaskCheckpointStatisticDetailsHandler.java | 4 +-
.../coordination/ClientCoordinationHandler.java | 4 +-
.../metrics/AbstractAggregatingMetricsHandler.java | 4 +-
.../job/metrics/AbstractMetricsHandler.java | 4 +-
.../job/metrics/AggregatingJobsMetricsHandler.java | 4 +-
.../metrics/AggregatingSubtasksMetricsHandler.java | 4 +-
.../AggregatingTaskManagersMetricsHandler.java | 4 +-
.../job/metrics/JobManagerMetricsHandler.java | 4 +-
.../metrics/JobManagerOperatorMetricsHandler.java | 4 +-
.../handler/job/metrics/JobMetricsHandler.java | 4 +-
.../job/metrics/JobVertexMetricsHandler.java | 4 +-
.../job/metrics/JobVertexWatermarksHandler.java | 4 +-
.../handler/job/metrics/SubtaskMetricsHandler.java | 4 +-
.../job/metrics/TaskManagerMetricsHandler.java | 4 +-
.../handler/job/rescaling/RescalingHandlers.java | 5 +-
.../job/savepoints/SavepointDisposalHandlers.java | 5 +-
.../handler/job/savepoints/SavepointHandlers.java | 10 +-
.../handler/legacy/DefaultExecutionGraphCache.java | 10 +-
.../legacy/files/StaticFileServerHandler.java | 4 +-
.../handler/legacy/metrics/MetricFetcherImpl.java | 8 +-
.../AbstractResourceManagerHandler.java | 4 +-
.../AbstractTaskManagerFileHandler.java | 9 +-
.../taskmanager/TaskManagerCustomLogHandler.java | 6 +-
.../taskmanager/TaskManagerDetailsHandler.java | 4 +-
.../taskmanager/TaskManagerLogFileHandler.java | 6 +-
.../taskmanager/TaskManagerLogListHandler.java | 4 +-
.../TaskManagerProfilingFileHandler.java | 6 +-
.../taskmanager/TaskManagerProfilingHandler.java | 4 +-
.../TaskManagerProfilingListHandler.java | 4 +-
.../taskmanager/TaskManagerStdoutFileHandler.java | 6 +-
.../taskmanager/TaskManagerThreadDumpHandler.java | 4 +-
.../handler/taskmanager/TaskManagersHandler.java | 4 +-
.../scheduler/DefaultExecutionDeployer.java | 13 +-
.../scheduler/DefaultExecutionGraphFactory.java | 8 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 4 +-
.../scheduler/DefaultSchedulerComponents.java | 6 +-
.../runtime/scheduler/DefaultSchedulerFactory.java | 6 +-
.../flink/runtime/scheduler/ExecutionDeployer.java | 4 +-
.../runtime/scheduler/SchedulerNGFactory.java | 6 +-
.../SlotSharingExecutionSlotAllocator.java | 6 +-
.../SlotSharingExecutionSlotAllocatorFactory.java | 9 +-
.../adaptive/AdaptiveSchedulerFactory.java | 6 +-
.../adaptivebatch/AdaptiveBatchScheduler.java | 4 +-
.../AdaptiveBatchSchedulerFactory.java | 8 +-
.../runtime/state/ttl/AbstractTtlDecorator.java | 2 +-
.../flink/runtime/state/ttl/TtlStateFactory.java | 2 +-
.../taskexecutor/DefaultJobLeaderService.java | 4 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 29 ++--
.../runtime/taskexecutor/TaskExecutorGateway.java | 25 +--
.../TaskExecutorGatewayDecoratorBase.java | 25 ++-
.../TaskExecutorThreadInfoGateway.java | 4 +-
.../TaskExecutorToResourceManagerConnection.java | 4 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 7 +-
.../TaskManagerServicesConfiguration.java | 8 +-
.../NonLeaderRetrievalRestfulGateway.java | 21 +--
.../flink/runtime/webmonitor/RestfulGateway.java | 37 ++---
.../runtime/webmonitor/WebMonitorEndpoint.java | 6 +-
.../flink/runtime/webmonitor/WebMonitorUtils.java | 8 +-
.../retriever/MetricQueryServiceGateway.java | 5 +-
.../threadinfo/ThreadInfoRequestCoordinator.java | 5 +-
.../threadinfo/VertexThreadInfoTracker.java | 5 +-
.../threadinfo/VertexThreadInfoTrackerBuilder.java | 7 +-
.../DefaultSchedulerCheckpointCoordinatorTest.java | 4 +-
.../runtime/dispatcher/AbstractDispatcherTest.java | 5 +-
.../DispatcherCachedOperationsHandlerTest.java | 17 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 12 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 4 +-
.../ExecutionGraphInfoStoreTestUtils.java | 4 +-
.../FileExecutionGraphInfoStoreTest.java | 10 +-
.../flink/runtime/dispatcher/JobMasterTester.java | 4 +-
.../MemoryExecutionGraphInfoStoreTest.java | 10 +-
.../runtime/dispatcher/MiniDispatcherTest.java | 6 +-
.../runtime/dispatcher/TestingDispatcher.java | 12 +-
.../CheckpointResourcesCleanupRunnerTest.java | 4 +-
.../runner/DefaultDispatcherRunnerITCase.java | 4 +-
.../ZooKeeperDefaultDispatcherRunnerTest.java | 4 +-
.../executiongraph/ExecutionGraphTestUtils.java | 5 +-
.../executiongraph/ExecutionJobVertexTest.java | 4 +-
.../executiongraph/ExecutionVertexCancelTest.java | 4 +-
.../ExecutionVertexDeploymentTest.java | 6 +-
.../InteractionsCountingTaskManagerGateway.java | 7 +-
.../TestingDefaultExecutionGraphBuilder.java | 6 +-
...estartBackoffTimeStrategyFactoryLoaderTest.java | 3 +-
.../utils/NotCancelAckingTaskGateway.java | 4 +-
.../utils/SimpleAckingTaskManagerGateway.java | 15 +-
...asterExecutionDeploymentReconciliationTest.java | 4 +-
.../jobmaster/JobMasterPartitionReleaseTest.java | 4 +-
.../jobmaster/JobMasterQueryableStateTest.java | 4 +-
.../runtime/jobmaster/JobMasterSchedulerTest.java | 6 +-
.../JobMasterServiceLeadershipRunnerTest.java | 3 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 17 +-
.../runtime/jobmaster/JobMasterTestUtils.java | 4 +-
.../runtime/jobmaster/TestingJobManagerRunner.java | 10 +-
.../PhysicalSlotRequestBulkCheckerImplTest.java | 12 +-
.../slotpool/SlotPoolBatchSlotRequestTest.java | 21 ++-
.../jobmaster/utils/TestingJobMasterGateway.java | 21 ++-
.../runtime/metrics/MetricRegistryImplTest.java | 4 +-
.../metrics/dump/MetricQueryServiceTest.java | 4 +-
.../dump/TestingMetricQueryServiceGateway.java | 4 +-
.../metrics/utils/SystemResourcesCounterTest.java | 5 +-
.../DefaultJobLeaderIdServiceTest.java | 14 +-
.../ResourceManagerJobMasterTest.java | 16 +-
.../ResourceManagerTaskExecutorTest.java | 6 +-
.../resourcemanager/ResourceManagerTest.java | 17 +-
.../StandaloneResourceManagerTest.java | 14 +-
.../resourcemanager/TestingResourceManager.java | 7 +-
.../TestingResourceManagerFactory.java | 6 +-
.../TestingResourceManagerService.java | 7 +-
.../active/ActiveResourceManagerTest.java | 15 +-
.../DefaultResourceAllocationStrategyTest.java | 6 +-
.../slotmanager/DefaultSlotStatusSyncerTest.java | 4 +-
...gerDefaultResourceAllocationStrategyITCase.java | 3 +-
.../FineGrainedSlotManagerTestBase.java | 4 +-
.../SlotManagerConfigurationBuilder.java | 9 +-
.../utils/MockResourceManagerRuntimeServices.java | 5 +-
.../utils/TestingResourceManagerGateway.java | 23 ++-
.../runtime/rest/RestClientMultipartTest.java | 4 +-
.../runtime/rest/RestExternalHandlersITCase.java | 7 +-
.../runtime/rest/RestServerEndpointITCase.java | 18 +--
.../runtime/rest/RestServerSSLAuthITCase.java | 4 +-
.../AbstractAsynchronousOperationHandlersTest.java | 8 +-
.../handler/job/JobCancellationHandlerTest.java | 4 +-
.../handler/job/JobExecutionResultHandlerTest.java | 4 +-
.../job/JobVertexBackPressureHandlerTest.java | 6 +-
.../job/JobVertexFlameGraphHandlerTest.java | 6 +-
.../SubtaskCurrentAttemptDetailsHandlerTest.java | 8 +-
...askExecutionAttemptAccumulatorsHandlerTest.java | 6 +-
.../SubtaskExecutionAttemptDetailsHandlerTest.java | 8 +-
.../AbstractCheckpointStatsHandlerTest.java | 7 +-
.../job/checkpoints/CheckpointHandlersTest.java | 4 +-
.../job/metrics/AbstractMetricsHandlerTest.java | 6 +-
.../metrics/AggregatingJobsMetricsHandlerTest.java | 4 +-
.../metrics/AggregatingMetricsHandlerTestBase.java | 6 +-
.../AggregatingSubtasksMetricsHandlerTest.java | 4 +-
.../AggregatingTaskManagersMetricsHandlerTest.java | 4 +-
.../metrics/JobVertexWatermarksHandlerTest.java | 4 +-
.../job/metrics/MetricsHandlerTestBase.java | 4 +-
.../job/savepoints/SavepointHandlersTest.java | 4 +-
.../savepoints/StopWithSavepointHandlersTest.java | 4 +-
.../legacy/DefaultExecutionGraphCacheTest.java | 30 ++--
.../handler/legacy/metrics/MetricFetcherTest.java | 10 +-
.../AbstractTaskManagerFileHandlerTest.java | 14 +-
.../TaskManagerStdoutFileHandlerTest.java | 8 +-
.../taskmanager/TestingTaskManagerFileHandler.java | 6 +-
.../TestingTaskManagerStdoutFileHandler.java | 6 +-
.../flink/runtime/rpc/FencedRpcEndpointTest.java | 28 ++--
.../scheduler/DefaultExecutionDeployerTest.java | 8 +-
.../DefaultExecutionGraphFactoryTest.java | 4 +-
.../DefaultSchedulerBatchSchedulingTest.java | 12 +-
.../runtime/scheduler/DefaultSchedulerBuilder.java | 6 +-
.../DefaultSchedulerComponentsFactoryTest.java | 7 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 9 +-
.../runtime/scheduler/SchedulerTestingUtils.java | 6 +-
.../SlotSharingExecutionSlotAllocatorTest.java | 4 +-
.../TestingPhysicalSlotRequestBulkChecker.java | 10 +-
.../scheduler/TestingSchedulerNGFactory.java | 6 +-
.../adaptive/AdaptiveSchedulerBuilder.java | 7 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 7 +-
.../flink/runtime/shuffle/ShuffleMasterTest.java | 4 +-
.../state/StateBackendMigrationTestBase.java | 12 +-
.../flink/runtime/state/StateBackendTestBase.java | 4 +-
.../flink/runtime/state/ttl/TtlStateTestBase.java | 4 +-
...cutorExecutionDeploymentReconciliationTest.java | 4 +-
.../TaskExecutorOperatorEventHandlingTest.java | 3 +-
.../TaskExecutorPartitionLifecycleTest.java | 5 +-
.../taskexecutor/TaskExecutorRecoveryTest.java | 4 +-
.../taskexecutor/TaskExecutorSubmissionTest.java | 3 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 19 +--
.../TaskSubmissionTestEnvironment.java | 6 +-
.../taskexecutor/TestingTaskExecutorGateway.java | 25 ++-
.../runtime/taskexecutor/slot/TaskSlotUtils.java | 8 +-
.../runtime/testutils/MiniClusterResource.java | 4 +-
.../MiniClusterResourceConfiguration.java | 14 +-
.../webmonitor/TestingDispatcherGateway.java | 16 +-
.../runtime/webmonitor/TestingRestfulGateway.java | 35 +++--
.../retriever/impl/RpcGatewayRetrieverTest.java | 12 +-
.../AbstractStreamOperatorTestHarnessTest.java | 7 +-
...logDelegateEmbeddedRocksDBStateBackendTest.java | 4 +-
.../ChangelogDelegateFileStateBackendTest.java | 4 +-
.../changelog/ChangelogDelegateHashMapTest.java | 4 +-
.../ChangelogDelegateMemoryStateBackendTest.java | 4 +-
.../state/ttl/RocksDbTtlCompactFiltersManager.java | 2 +-
.../handler/AbstractSqlGatewayRestHandler.java | 4 +-
.../table/gateway/rest/RestAPIITCaseBase.java | 4 +-
.../gateway/rest/SqlGatewayRestEndpointITCase.java | 17 +-
.../org/apache/flink/table/api/TableConfig.java | 9 +-
.../stream/ChangelogModeInferenceTest.scala | 1 -
.../stream/sql/MiniBatchIntervalInferTest.scala | 7 +-
.../stream/sql/agg/DistinctAggregateTest.scala | 1 -
.../plan/stream/sql/agg/GroupWindowTest.scala | 1 -
.../stream/sql/agg/TwoStageAggregateTest.scala | 1 -
.../plan/stream/table/TwoStageAggregateTest.scala | 1 -
...AbstractTwoInputStreamOperatorWithTTLTest.scala | 12 +-
.../runtime/stream/sql/GroupWindowITCase.scala | 11 +-
.../runtime/stream/sql/MatchRecognizeITCase.scala | 30 ++--
.../runtime/stream/table/GroupWindowITCase.scala | 1 -
.../table/GroupWindowTableAggregateITCase.scala | 1 -
.../planner/runtime/stream/table/JoinITCase.scala | 1 -
.../stream/table/TableAggregateITCase.scala | 1 -
.../runtime/utils/StreamingWithAggTestBase.scala | 1 -
.../operators/rank/AppendOnlyTopNFunction.java | 2 +-
.../runtime/operators/rank/FastTop1Function.java | 2 +-
.../operators/rank/UpdatableTopNFunction.java | 2 +-
.../flink/table/runtime/util/StateConfigUtil.java | 5 +-
.../ProcTimeDeduplicateFunctionTestBase.java | 5 +-
...rocTimeDeduplicateKeepFirstRowFunctionTest.java | 4 +-
...ProcTimeDeduplicateKeepLastRowFunctionTest.java | 2 +-
...niBatchDeduplicateKeepFirstRowFunctionTest.java | 4 +-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 8 +-
.../RowTimeDeduplicateFunctionTest.java | 12 +-
.../RowTimeDeduplicateFunctionTestBase.java | 5 +-
...niBatchLatestChangeDeduplicateFunctionTest.java | 2 +-
.../datastream/DataStreamBatchExecutionITCase.java | 4 +-
.../jobmaster/JobMasterTriggerSavepointITCase.java | 4 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 3 +-
.../recovery/BatchFineGrainedRecoveryITCase.java | 4 +-
.../JobManagerHAProcessFailureRecoveryITCase.java | 8 +-
.../TaskManagerDisconnectOnShutdownITCase.java | 7 +-
.../ZooKeeperLeaderElectionITCase.java | 3 +-
.../test/scheduling/AdaptiveSchedulerITCase.java | 4 +-
.../yarn/YARNSessionCapacitySchedulerITCase.java | 4 +-
.../apache/flink/yarn/YarnConfigurationITCase.java | 4 +-
387 files changed, 1336 insertions(+), 1808 deletions(-)
delete mode 100644
flink-core/src/main/java/org/apache/flink/api/common/time/Time.java
