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 f7d280ec1de [FLINK-36066][runtime] Introduce the AdaptiveGraphManager
component
add 0feefe9a40b [FLINK-36822][build] Enable spotless for java 21
No new revisions were added by this update.
Summary of changes:
.../rest/RestClusterClientConfiguration.java | 12 ++++--
.../base/source/reader/fetcher/SplitFetcher.java | 1 +
.../source/reader/splitreader/SplitsChange.java | 4 +-
.../base/table/options/TableOptionsUtils.java | 4 +-
.../sink/compactor/RecordWiseFileCompactor.java | 4 +-
.../table/stream/PartitionTimeCommitPredicate.java | 1 +
.../connector/file/table/stream/TaskTracker.java | 4 +-
.../file/src/testutils/TestingFileSystem.java | 1 +
.../functions/sink/filesystem/BucketWriter.java | 4 +-
.../sink/filesystem/InProgressFileWriter.java | 8 +++-
.../functions/sink/filesystem/PartFileInfo.java | 12 ++++--
.../sink/filesystem/WriterProperties.java | 8 +++-
.../java/typeutils/runtime/WritableSerializer.java | 1 +
.../org/apache/flink/api/java/tuple/Tuple.java | 1 +
.../org/apache/flink/api/java/tuple/Tuple10.java | 9 +++++
.../org/apache/flink/api/java/tuple/Tuple11.java | 10 +++++
.../org/apache/flink/api/java/tuple/Tuple12.java | 11 ++++++
.../org/apache/flink/api/java/tuple/Tuple13.java | 12 ++++++
.../org/apache/flink/api/java/tuple/Tuple14.java | 13 +++++++
.../org/apache/flink/api/java/tuple/Tuple15.java | 14 +++++++
.../org/apache/flink/api/java/tuple/Tuple16.java | 15 ++++++++
.../org/apache/flink/api/java/tuple/Tuple17.java | 16 ++++++++
.../org/apache/flink/api/java/tuple/Tuple18.java | 17 +++++++++
.../org/apache/flink/api/java/tuple/Tuple19.java | 18 +++++++++
.../org/apache/flink/api/java/tuple/Tuple2.java | 1 +
.../org/apache/flink/api/java/tuple/Tuple20.java | 19 ++++++++++
.../org/apache/flink/api/java/tuple/Tuple21.java | 20 ++++++++++
.../org/apache/flink/api/java/tuple/Tuple22.java | 21 +++++++++++
.../org/apache/flink/api/java/tuple/Tuple23.java | 22 +++++++++++
.../org/apache/flink/api/java/tuple/Tuple24.java | 23 +++++++++++
.../org/apache/flink/api/java/tuple/Tuple25.java | 24 ++++++++++++
.../org/apache/flink/api/java/tuple/Tuple3.java | 2 +
.../org/apache/flink/api/java/tuple/Tuple4.java | 3 ++
.../org/apache/flink/api/java/tuple/Tuple5.java | 4 ++
.../org/apache/flink/api/java/tuple/Tuple6.java | 5 +++
.../org/apache/flink/api/java/tuple/Tuple7.java | 6 +++
.../org/apache/flink/api/java/tuple/Tuple8.java | 7 ++++
.../org/apache/flink/api/java/tuple/Tuple9.java | 8 ++++
.../api/java/tuple/builder/Tuple19Builder.java | 3 +-
.../api/java/tuple/builder/Tuple20Builder.java | 3 +-
.../api/java/tuple/builder/Tuple21Builder.java | 3 +-
.../api/java/tuple/builder/Tuple22Builder.java | 3 +-
.../api/java/tuple/builder/Tuple23Builder.java | 3 +-
.../api/java/tuple/builder/Tuple24Builder.java | 3 +-
.../api/java/tuple/builder/Tuple25Builder.java | 3 +-
.../flink/api/common/accumulators/Accumulator.java | 8 +++-
.../apache/flink/api/common/io/OutputFormat.java | 1 +
.../api/common/operators/OperatorInformation.java | 4 +-
.../common/operators/base/BulkIterationBase.java | 32 ++++++++++++----
.../common/operators/base/CoGroupOperatorBase.java | 4 +-
.../operators/base/CoGroupRawOperatorBase.java | 4 +-
.../common/operators/base/CrossOperatorBase.java | 4 +-
.../common/operators/base/FilterOperatorBase.java | 4 +-
.../common/operators/base/FlatMapOperatorBase.java | 4 +-
.../operators/base/GroupReduceOperatorBase.java | 4 +-
.../operators/base/InnerJoinOperatorBase.java | 4 +-
.../operators/base/PartitionOperatorBase.java | 4 +-
.../operators/base/SortPartitionOperatorBase.java | 4 +-
.../flink/api/common/state/StateDescriptor.java | 4 +-
.../api/connector/sink2/CommitterInitContext.java | 4 +-
.../api/connector/sink2/WriterInitContext.java | 4 +-
.../flink/api/connector/source/ReaderInfo.java | 8 +++-
.../api/connector/source/SourceReaderContext.java | 8 +++-
.../api/connector/source/SplitsAssignment.java | 4 +-
.../flink/api/java/typeutils/RowTypeInfo.java | 1 +
.../flink/api/java/typeutils/TypeExtractor.java | 4 +-
.../api/java/typeutils/runtime/RowComparator.java | 9 ++++-
.../typeutils/runtime/TupleComparatorBase.java | 1 +
.../apache/flink/configuration/ClusterOptions.java | 4 +-
.../flink/configuration/ConfigConstants.java | 1 +
.../flink/configuration/JobManagerOptions.java | 8 +++-
.../apache/flink/configuration/MetricOptions.java | 2 +
.../flink/configuration/PipelineOptions.java | 1 +
.../flink/configuration/StateRecoveryOptions.java | 1 +
.../flink/configuration/TaskManagerOptions.java | 1 +
...erFromPersistRecoverableFsDataOutputStream.java | 4 +-
.../apache/flink/core/fs/ICloseableRegistry.java | 4 +-
.../flink/core/state/CompletedStateFuture.java | 1 +
.../main/java/org/apache/flink/types/Either.java | 8 +++-
.../java/org/apache/flink/types/ListValue.java | 1 +
.../main/java/org/apache/flink/types/Record.java | 11 ++++--
.../java/org/apache/flink/types/StringValue.java | 1 +
.../main/java/org/apache/flink/util/IOUtils.java | 4 +-
.../org/apache/flink/util/OptionalFailure.java | 8 +++-
.../apache/flink/util/concurrent/FutureUtils.java | 4 +-
.../flink/util/concurrent/RetryStrategy.java | 12 ++++--
.../flink/api/common/io/FileInputFormatTest.java | 1 +
.../apache/flink/core/fs/InitOutputPathTest.java | 4 +-
.../configuration/ConfigOptionsDocGenerator.java | 1 +
.../org/apache/flink/changelog/fs/RetryPolicy.java | 4 +-
.../flink/changelog/fs/RetryingExecutor.java | 1 +
.../s3/model/transform/XmlResponsesSaxParser.java | 21 ++++++++---
.../DebeziumAvroDeserializationSchema.java | 3 ++
.../debezium/DebeziumAvroSerializationSchema.java | 1 +
.../formats/avro/AvroSerializationSchema.java | 1 +
.../flink/formats/csv/RowDataToCsvConverters.java | 4 +-
.../orc/vector/OrcVectorizedBatchWrapper.java | 4 +-
.../vector/reader/NestedPrimitiveColumnReader.java | 2 +
.../vector/reader/ParquetDataColumnReader.java | 44 ++++++++++++++++------
.../apache/flink/formats/protobuf/PbConstant.java | 1 +
.../flink/kubernetes/utils/KubernetesUtils.java | 4 +-
.../apache/flink/cep/nfa/compiler/NFACompiler.java | 4 +-
.../flink/cep/nfa/sharedbuffer/SharedBuffer.java | 1 +
.../java/org/apache/flink/cep/pattern/Pattern.java | 4 +-
.../cep/pattern/conditions/BooleanConditions.java | 8 +++-
.../cep/pattern/conditions/RichAndCondition.java | 8 +++-
.../cep/pattern/conditions/RichOrCondition.java | 8 +++-
.../java/org/apache/flink/cep/nfa/NFAITCase.java | 1 +
.../state/api/StateBootstrapTransformation.java | 4 +-
.../api/functions/KeyedStateReaderFunction.java | 8 +++-
.../state/api/functions/WindowReaderFunction.java | 8 +++-
.../flink/state/api/output/FileCopyFunction.java | 4 +-
.../api/runtime/metadata/SavepointMetadataV2.java | 4 +-
.../java/org/apache/flink/metrics/MeterView.java | 4 ++
.../flink/metrics/otel/OpenTelemetryTestBase.java | 8 +++-
.../control/DefaultJobBundleFactory.java | 1 +
.../apache/beam/sdk/fn/server/ServerFactory.java | 1 +
.../apache/flink/client/python/PythonEnvUtils.java | 11 ++++--
.../flink/python/util/PythonDependencyUtils.java | 8 +++-
.../state/serialization/KvStateSerializer.java | 1 +
.../org/apache/flink/runtime/rpc/RpcEndpoint.java | 1 +
.../runtime/asyncprocessing/EpochManager.java | 1 +
.../checkpoint/AbstractCheckpointStats.java | 12 ++++--
.../runtime/checkpoint/CheckpointCoordinator.java | 4 +-
.../checkpoint/CheckpointFailureManager.java | 4 +-
.../runtime/checkpoint/CheckpointOptions.java | 1 +
.../runtime/checkpoint/DefaultCheckpointPlan.java | 6 ++-
.../flink/runtime/checkpoint/OperatorState.java | 4 +-
.../RoundRobinOperatorStateRepartitioner.java | 6 ++-
.../checkpoint/StateAssignmentOperation.java | 1 +
.../runtime/checkpoint/SubtaskStateStats.java | 8 +++-
.../runtime/checkpoint/TaskStateAssignment.java | 3 ++
.../flink/runtime/checkpoint/TaskStateStats.java | 16 ++++++--
.../channel/ChannelStateWriteRequestExecutor.java | 4 +-
.../checkpoint/filemerging/PhysicalFile.java | 4 +-
.../deployment/InputGateDeploymentDescriptor.java | 1 +
.../dispatcher/JobManagerMetricGroupFactory.java | 4 +-
.../flink/runtime/execution/Environment.java | 4 +-
.../executiongraph/ArchivedExecutionGraph.java | 1 +
.../executiongraph/ExecutionGraphUtils.java | 4 +-
.../executiongraph/SpeculativeExecutionVertex.java | 8 ++--
.../flink/runtime/io/AvailabilityProvider.java | 8 +++-
.../flink/runtime/io/PullingAsyncDataInput.java | 4 +-
.../runtime/io/disk/iomanager/IOManagerAsync.java | 3 +-
.../runtime/io/network/api/RecoveryMetadata.java | 4 +-
...SpillingAdaptiveSpanningRecordDeserializer.java | 4 +-
.../flink/runtime/io/network/buffer/Buffer.java | 9 ++++-
.../runtime/io/network/buffer/BufferConsumer.java | 4 +-
.../io/network/partition/DeduplicatedQueue.java | 4 +-
.../io/network/partition/PrioritizedDeque.java | 4 +-
.../partition/consumer/RemoteInputChannel.java | 4 +-
.../network/partition/consumer/UnionInputGate.java | 1 +
.../storage/TieredStorageMemoryManagerImpl.java | 4 +-
.../concurrent/SolutionSetUpdateBarrierBroker.java | 4 +-
.../iterative/task/AbstractIterativeTask.java | 4 +-
.../tasks/CheckpointCoordinatorConfiguration.java | 4 +-
.../runtime/memory/AbstractPagedInputView.java | 4 +-
.../runtime/memory/AbstractPagedOutputView.java | 4 +-
.../apache/flink/runtime/memory/MemoryManager.java | 1 +
.../messages/webmonitor/ClusterOverview.java | 1 +
.../runtime/messages/webmonitor/JobDetails.java | 1 +
.../flink/runtime/metrics/ReporterSetup.java | 4 +-
.../apache/flink/runtime/metrics/TimerGauge.java | 7 +++-
.../flink/runtime/metrics/TraceReporterSetup.java | 4 +-
.../flink/runtime/metrics/dump/MetricDump.java | 1 +
.../flink/runtime/metrics/scope/ScopeFormats.java | 1 +
.../org/apache/flink/runtime/net/SSLUtils.java | 5 ++-
.../apache/flink/runtime/operators/BatchTask.java | 4 +-
.../operators/hash/CompactingHashTable.java | 16 ++++++--
.../runtime/operators/hash/InMemoryPartition.java | 8 +++-
.../operators/hash/InPlaceMutableHashTable.java | 4 +-
.../runtime/operators/sort/CircularQueues.java | 1 +
.../runtime/operators/sort/SorterInputGateway.java | 1 +
.../apache/flink/runtime/query/KvStateInfo.java | 12 ++++--
.../runtime/resourcemanager/ResourceManager.java | 1 +
.../slotmanager/DefaultSlotStatusSyncer.java | 1 +
.../slotmanager/FineGrainedSlotManager.java | 9 +++--
.../rest/RestServerEndpointConfiguration.java | 4 +-
.../rest/handler/legacy/metrics/MetricFetcher.java | 4 +-
.../rest/handler/router/MethodlessRouter.java | 4 +-
.../runtime/rest/handler/router/PathPattern.java | 1 +
.../messages/TerminationModeQueryParameter.java | 4 +-
.../scheduler/adaptive/JobSchedulingPlan.java | 1 +
.../scheduler/adaptive/StopWithSavepoint.java | 1 +
.../exceptionhistory/ExceptionHistoryEntry.java | 1 +
.../flink/runtime/shuffle/JobShuffleContext.java | 4 +-
.../runtime/shuffle/ShuffleMasterContext.java | 4 +-
.../source/coordinator/SourceCoordinator.java | 6 +++
.../runtime/source/event/SourceEventWrapper.java | 4 +-
.../runtime/state/AbstractChannelStateHandle.java | 1 +
.../runtime/state/AbstractKeyedStateBackend.java | 32 ++++++++++++----
.../state/DefaultOperatorStateBackendBuilder.java | 3 ++
.../runtime/state/InternalKeyContextImpl.java | 2 +
.../apache/flink/runtime/state/KeyGroupRange.java | 12 ++++--
.../flink/runtime/state/KeyGroupsStateHandle.java | 8 +++-
.../flink/runtime/state/KeyedStateBackend.java | 8 +++-
.../state/OperatorBackendSerializationProxy.java | 1 +
.../flink/runtime/state/PriorityComparable.java | 4 +-
.../runtime/state/SharedStateRegistryImpl.java | 1 +
.../apache/flink/runtime/state/StateBackend.java | 16 ++++++--
.../flink/runtime/state/StreamStateHandle.java | 8 +++-
.../runtime/state/TestableKeyedStateBackend.java | 1 +
.../changelog/ChangelogStateHandleStreamImpl.java | 1 +
.../changelog/LocalChangelogRegistryImpl.java | 1 +
.../state/changelog/SequenceNumberRange.java | 9 ++++-
.../runtime/state/heap/CopyOnWriteStateMap.java | 4 +-
.../state/heap/HeapKeyValueStateIterator.java | 4 ++
.../state/heap/HeapKeyedStateBackendBuilder.java | 2 +
.../state/storage/FileSystemCheckpointStorage.java | 4 +-
.../state/storage/JobManagerCheckpointStorage.java | 8 +++-
.../org/apache/flink/runtime/taskmanager/Task.java | 1 +
.../flink/runtime/throughput/BufferSizeEMA.java | 1 +
.../runtime/throughput/ThroughputCalculator.java | 4 +-
.../flink/runtime/util/EnvironmentInformation.java | 16 ++++++--
.../apache/flink/runtime/util/IntArrayList.java | 3 +-
.../api/connector/sink2/CommittableSummary.java | 3 ++
.../api/functions/co/ProcessJoinFunction.java | 12 ++++--
.../api/functions/sink/legacy/SinkFunction.java | 4 +-
.../source/ContinuousFileReaderOperator.java | 2 +
.../source/TimestampedFileInputSplit.java | 8 +++-
.../functions/source/TimestampedInputSplit.java | 8 +++-
.../windowing/ProcessAllWindowFunction.java | 4 +-
.../flink/streaming/api/graph/StreamConfig.java | 1 +
.../flink/streaming/api/graph/StreamEdge.java | 1 +
.../streaming/api/graph/StreamGraphGenerator.java | 3 +-
.../flink/streaming/api/graph/StreamNode.java | 1 +
.../api/graph/StreamingJobGraphGenerator.java | 16 +++++---
.../api/operators/InputFormatOperatorFactory.java | 4 +-
.../streaming/api/operators/InputSelection.java | 4 +-
.../api/operators/InternalTimeServiceManager.java | 4 +-
.../streaming/api/operators/InternalTimer.java | 1 +
.../api/operators/MailboxWatermarkProcessor.java | 1 +
.../api/operators/OperatorSnapshotFutures.java | 4 +-
.../api/operators/OutputFormatOperatorFactory.java | 4 +-
.../streaming/api/operators/SourceOperator.java | 1 +
.../operators/StreamTaskStateInitializerImpl.java | 6 ++-
.../api/operators/UdfStreamOperatorFactory.java | 8 +++-
.../api/operators/util/PausableRelativeClock.java | 5 ++-
.../api/transformations/CacheTransformation.java | 1 +
.../flink/streaming/api/watermark/Watermark.java | 2 +
.../runtime/io/AbstractStreamTaskNetworkInput.java | 1 +
.../io/MultipleFuturesAvailabilityHelper.java | 4 +-
.../runtime/io/MultipleInputSelectionHandler.java | 2 +-
.../runtime/io/StreamMultipleInputProcessor.java | 1 +
.../io/checkpointing/CheckpointedInputGate.java | 4 +-
.../operators/sink/GlobalCommitterOperator.java | 1 +
.../runtime/operators/sink/SinkWriterOperator.java | 1 +
.../sink/committables/CommittableCollector.java | 1 +
.../CommittableCollectorSerializer.java | 2 +
.../operators/windowing/TimestampedValue.java | 8 +++-
.../runtime/tasks/AsyncCheckpointRunnable.java | 4 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 4 ++
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 1 +
.../streaming/runtime/tasks/mailbox/Mail.java | 3 ++
.../runtime/tasks/mailbox/TaskMailbox.java | 1 +
.../CheckpointSettingsSerializableTest.java | 2 +
.../cleanup/CleanupRetryStrategyFactoryTest.java | 1 +
.../BlobLibraryCacheRecoveryITCase.java | 1 +
.../flink/runtime/jobmaster/JobMasterTest.java | 3 +-
.../memory/MemoryManagerSharedResourcesTest.java | 1 +
.../drivers/AllGroupReduceDriverTest.java | 1 +
.../operators/drivers/AllReduceDriverTest.java | 1 +
.../operators/drivers/ReduceDriverTest.java | 1 +
.../runtime/operators/hash/HashTableITCase.java | 6 ++-
.../runtime/operators/hash/HashTableTest.java | 3 +-
.../hash/NonReusingHashJoinIteratorITCase.java | 36 ++++++++++++------
.../hash/NonReusingReOpenableHashTableITCase.java | 6 ++-
.../hash/ReusingHashJoinIteratorITCase.java | 36 ++++++++++++------
.../hash/ReusingReOpenableHashTableITCase.java | 6 ++-
.../AbstractSortMergeOuterJoinIteratorITCase.java | 6 ++-
...NonReusingSortMergeInnerJoinIteratorITCase.java | 6 ++-
.../ReusingSortMergeInnerJoinIteratorITCase.java | 6 ++-
.../operators/testutils/DriverTestBase.java | 4 +-
.../testutils/types/IntPairSerializer.java | 3 +-
.../operators/util/HashVsSortMiniBenchmark.java | 12 ++++--
.../slotmanager/DefaultSlotStatusSyncerTest.java | 8 +++-
.../rest/compatibility/CompatibilityRoutines.java | 4 +-
.../taskmanager/TaskManagerDetailsHandlerTest.java | 7 +++-
.../flink/runtime/state/StateBackendTestBase.java | 4 +-
.../flink/runtime/state/TestStreamStateHandle.java | 1 +
.../runtime/testutils/MiniClusterResource.java | 4 +-
.../runtime/testutils/ZooKeeperTestUtils.java | 4 +-
.../ThreadInfoRequestCoordinatorTest.java | 3 +-
.../runtime/tasks/mailbox/TaskMailboxImplTest.java | 1 +
.../changelog/ChangelogKeyedStateBackend.java | 1 +
.../apache/flink/state/forst/ForStMapState.java | 1 +
.../state/forst/ForStNativeMetricOptions.java | 12 ++++--
.../flink/state/forst/ForStStateBackend.java | 1 +
.../flink/state/forst/fs/cache/FileBasedCache.java | 1 +
.../forst/fs/cache/SizeBasedCacheLimitPolicy.java | 1 +
.../flink/state/forst/ForStStateBackendTest.java | 4 +-
.../flink/runtime/state/heap/space/Chunk.java | 8 +++-
.../state/rocksdb/EmbeddedRocksDBStateBackend.java | 1 +
.../state/rocksdb/RocksDBNativeMetricOptions.java | 12 ++++--
.../restore/RocksDBFullRestoreOperation.java | 1 +
.../RocksDBHeapTimersFullRestoreOperation.java | 1 +
.../snapshot/RocksDBSnapshotStrategyBase.java | 1 +
.../api/functions/async/AsyncRetryStrategy.java | 12 ++++--
.../api/operators/async/AsyncWaitOperator.java | 3 ++
.../table/client/cli/CliChangelogResultView.java | 2 +-
.../client/cli/parser/SqlMultiLineParser.java | 4 ++
.../table/client/gateway/DefaultContextUtils.java | 1 +
.../flink/table/client/gateway/ExecutorImpl.java | 3 +-
.../table/gateway/api/results/FunctionInfo.java | 1 +
.../rest/serde/LogicalTypeJsonSerializer.java | 2 +-
.../service/operation/OperationExecutor.java | 15 ++++++--
.../service/operation/OperationManager.java | 1 +
.../service/context/SessionContextTest.java | 10 ++++-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 1 +
.../legacy/table/descriptors/SchemaValidator.java | 4 +-
.../wmstrategies/BoundedOutOfOrderTimestamps.java | 4 +-
.../org/apache/flink/table/api/CompiledPlan.java | 16 ++++++--
.../org/apache/flink/table/api/Expressions.java | 1 +
.../org/apache/flink/table/api/PlanReference.java | 8 +++-
.../org/apache/flink/table/api/TableConfig.java | 4 +-
.../table/api/internal/TableEnvironmentImpl.java | 5 ++-
.../apache/flink/table/catalog/CatalogManager.java | 6 ++-
.../table/catalog/ContextResolvedFunction.java | 4 +-
.../flink/table/catalog/ContextResolvedModel.java | 4 +-
.../flink/table/catalog/ContextResolvedTable.java | 4 +-
.../table/catalog/GenericInMemoryCatalog.java | 12 ++++--
.../flink/table/delegation/InternalPlan.java | 8 +++-
.../table/expressions/ApiExpressionUtils.java | 12 ++++--
.../flink/table/factories/TableFactoryUtil.java | 6 ++-
.../legacy/sources/tsextractors/ExistingField.java | 4 +-
.../table/operations/ShowFunctionsOperation.java | 4 +-
.../operations/utils/OperationTreeBuilder.java | 4 +-
.../flink/table/resource/ResourceManager.java | 1 +
.../table/codesplit/BlockStatementGrouper.java | 12 ++++--
.../flink/table/codesplit/DeclarationRewriter.java | 4 +-
.../java/org/apache/flink/table/api/DataTypes.java | 4 +-
.../org/apache/flink/table/catalog/Catalog.java | 12 ++++--
.../table/catalog/exceptions/CatalogException.java | 8 +++-
.../apache/flink/table/connector/Projection.java | 4 +-
.../abilities/SupportsProjectionPushDown.java | 4 +-
.../flink/table/data/binary/BinaryFormat.java | 2 +
.../flink/table/expressions/CallExpression.java | 4 +-
.../flink/table/factories/CatalogFactory.java | 8 +++-
.../flink/table/factories/ModuleFactory.java | 8 +++-
.../table/functions/BuiltInFunctionDefinition.java | 8 +++-
.../apache/flink/table/legacy/api/TableColumn.java | 8 +++-
.../apache/flink/table/legacy/api/TableSchema.java | 8 +++-
.../flink/table/legacy/descriptors/Schema.java | 1 +
.../table/legacy/factories/TableSinkFactory.java | 8 +++-
.../table/legacy/factories/TableSourceFactory.java | 8 +++-
.../apache/flink/table/legacy/sinks/TableSink.java | 8 +++-
.../table/types/inference/InputTypeStrategies.java | 4 +-
.../flink/table/types/inference/TypeInference.java | 16 ++++++--
.../WindowTimeIndictorInputTypeStrategy.java | 4 +-
.../flink/table/types/logical/SymbolType.java | 8 +++-
.../flink/table/types/utils/DataTypeUtils.java | 4 +-
.../apache/flink/table/utils/EncodingUtils.java | 10 ++---
.../flink/table/factories/TestCatalogFactory.java | 12 ++++--
.../types/extraction/DataTypeExtractorTest.java | 1 +
.../calcite/rel/logical/LogicalTableScan.java | 1 +
.../main/java/org/apache/calcite/rex/RexUtil.java | 4 +-
.../calcite/sql/fun/SqlTimestampAddFunction.java | 1 +
.../calcite/sql/validate/SqlValidatorImpl.java | 12 +++---
.../apache/calcite/sql2rel/RelDecorrelator.java | 2 +-
.../apache/calcite/sql2rel/SqlToRelConverter.java | 28 +++++++-------
.../calcite/sql2rel/StandardConvertletTable.java | 7 ++--
.../java/org/apache/calcite/tools/RelBuilder.java | 9 +++--
.../table/planner/delegation/PlannerContext.java | 4 +-
.../functions/aggfunctions/AvgAggFunction.java | 14 +++----
.../functions/aggfunctions/Count1AggFunction.java | 8 ++--
.../functions/aggfunctions/CountAggFunction.java | 8 ++--
.../functions/aggfunctions/MaxAggFunction.java | 6 +--
.../functions/aggfunctions/MinAggFunction.java | 6 +--
.../functions/aggfunctions/NTILEAggFunction.java | 6 +--
.../aggfunctions/SingleValueAggFunction.java | 2 +-
.../functions/aggfunctions/Sum0AggFunction.java | 22 +++++------
.../functions/aggfunctions/SumAggFunction.java | 6 +--
.../aggfunctions/SumWithRetractAggFunction.java | 14 +++----
.../table/planner/functions/casting/CastRule.java | 4 +-
.../planner/functions/casting/CastRuleUtils.java | 2 +-
.../functions/casting/CodeGeneratorCastRule.java | 16 ++++++--
.../planner/functions/sql/BuiltInSqlFunction.java | 12 ++++--
.../planner/functions/sql/BuiltInSqlOperator.java | 12 ++++--
.../table/planner/plan/nodes/exec/ExecEdge.java | 3 ++
.../planner/plan/nodes/exec/ExecNodeConfig.java | 12 ++++--
.../planner/plan/nodes/exec/InputProperty.java | 1 +
.../plan/nodes/exec/serde/JsonPlanEdge.java | 3 ++
.../exec/serde/LogicalTypeJsonSerializer.java | 4 +-
.../planner/plan/nodes/exec/spec/SortSpec.java | 2 +
.../exec/stream/StreamExecGroupTableAggregate.java | 3 ++
.../SplitPythonConditionFromCorrelateRule.java | 4 +-
.../planner/plan/trait/MiniBatchInterval.java | 1 +
.../typeutils/LogicalRelDataTypeConverter.java | 2 +-
.../testcsv/TestCsvSerializationSchema.java | 4 +-
.../plan/nodes/exec/TransformationsTest.java | 19 +++++++---
.../plan/nodes/exec/testutils/RestoreTestBase.java | 6 ++-
.../exec/testutils/RestoreTestCompleteness.java | 15 ++++++--
.../runtime/stream/sql/DataStreamJavaITCase.java | 2 +-
.../table/runtime/context/ExecutionContext.java | 4 +-
.../aggregate/hyperloglog/HyperLogLogPlusPlus.java | 1 +
.../table/lookup/fullcache/CacheLoader.java | 4 +-
.../table/runtime/generated/FilterCondition.java | 4 +-
.../table/runtime/generated/JoinCondition.java | 4 +-
.../runtime/hashtable/BaseHybridHashTable.java | 1 +
.../runtime/hashtable/BinaryHashPartition.java | 1 +
.../runtime/hashtable/HashTableBloomFilter.java | 4 +-
.../runtime/hashtable/LongHybridHashTable.java | 1 +
.../ProcTimeDeduplicateKeepLastRowFunction.java | 1 +
.../join/lookup/AsyncLookupJoinRunner.java | 1 +
.../TableOperatorWrapperGenerator.java | 1 +
.../multipleinput/input/InputSelectionHandler.java | 1 +
.../sort/AbstractBinaryExternalMerger.java | 12 ++++--
.../operators/window/grouping/WindowsGrouping.java | 8 +++-
.../assigners/InternalTimeWindowAssigner.java | 8 +++-
.../assigners/TumblingWindowAssigner.java | 1 +
.../internal/InternalWindowProcessFunction.java | 4 +-
.../table/runtime/types/PlannerTypeUtils.java | 8 ++--
.../table/runtime/util/MemorySegmentPool.java | 4 +-
.../collections/binary/AbstractBytesHashMap.java | 12 ++++--
.../collections/binary/AbstractBytesMultiMap.java | 4 +-
.../runtime/util/collections/binary/BytesMap.java | 8 +++-
.../container/FlinkContainersSettings.java | 1 +
.../container/TestcontainersSettings.java | 20 +++++++---
.../testutils/catalog/TestFileSystemCatalog.java | 12 ++++--
.../flink/core/testutils/FlinkAssertions.java | 4 +-
.../flink/testutils/junit/SharedObjects.java | 2 +
.../testutils/junit/SharedObjectsExtension.java | 2 +
.../test/accumulators/AccumulatorLiveITCase.java | 3 +-
.../ApproximateLocalRecoveryDownstreamITCase.java | 2 +
.../checkpointing/ChangelogRecoveryITCaseBase.java | 4 +-
.../flink/test/checkpointing/SavepointITCase.java | 1 +
.../UnalignedCheckpointStressITCase.java | 4 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 1 +
.../jar/CheckpointedStreamingProgram.java | 1 +
.../classloading/jar/CustomInputSplitProgram.java | 1 +
.../jar/StreamingCustomInputSplitProgram.java | 1 +
.../test/classloading/jar/StreamingProgram.java | 1 +
.../TypeSerializerTestCoverageTest.java | 3 +-
.../recovery/BatchFineGrainedRecoveryITCase.java | 3 +-
.../flink/test/state/ChangelogRescalingITCase.java | 4 ++
.../streaming/api/FileReadingWatermarkITCase.java | 1 +
.../windowing/sessionwindows/EventGenerator.java | 12 ++++--
.../sessionwindows/LongRandomGenerator.java | 4 +-
.../ParallelSessionsEventGenerator.java | 8 +++-
.../sessionwindows/SessionEventGeneratorImpl.java | 36 +++++++++++++-----
.../windowing/sessionwindows/TestEventPayload.java | 8 +++-
.../java/org/apache/flink/yarn/YarnTestBase.java | 4 +-
.../apache/flink/yarn/YarnClusterDescriptor.java | 2 +-
.../flink/yarn/YarnResourceManagerDriver.java | 3 +-
.../yarn/configuration/YarnConfigOptions.java | 4 +-
.../YarnApplicationClusterEntryPoint.java | 4 +-
pom.xml | 16 +-------
.../tools/ci/licensecheck/NoticeFileChecker.java | 3 +-
.../flink/tools/ci/utils/deploy/DeployParser.java | 3 +-
449 files changed, 1910 insertions(+), 591 deletions(-)
