diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 index ead0298be74ea..c53c7b0d54480 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 @@ -19,7 +19,7 @@ Method calls method in (TaskManagerConfiguration.java:240) Method calls method in (TaskManagerServices.java:481) Method calls method in (TaskManagerServices.java:479) -Method calls method in (SourceOperator.java:317) -Method calls method in (SourceOperator.java:323) +Method calls method in (SourceOperator.java:321) +Method calls method in (SourceOperator.java:327) Method calls method in (SourceOperatorStreamTask.java:101) -Method calls method in (MailboxExecutorImpl.java:63) +Method calls method in (MailboxExecutorImpl.java:64) diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e index e7b19213c29dc..e8e2bdbd5cdd8 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e @@ -44,9 +44,9 @@ Constructor ( Constructor ([Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;, java.lang.String, org.apache.flink.table.types.DataType, long, java.lang.Long, java.lang.Integer)> has parameter of type <[Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;> in (DataGenTableSource.java:0) Constructor (java.lang.String, org.apache.flink.configuration.ReadableConfig)> calls constructor ()> in (DataGenVisitorBase.java:49) Constructor (org.apache.flink.streaming.api.functions.source.datagen.DataGenerator, java.util.Set)> has parameter of type in (DataGeneratorContainer.java:0) -Constructor (int)> calls constructor ()> in (RandomGeneratorVisitor.java:458) -Constructor (java.time.Duration)> calls constructor ()> in (RandomGeneratorVisitor.java:473) -Constructor (int)> calls constructor ()> in (RandomGeneratorVisitor.java:488) +Constructor (int)> calls constructor ()> in (RandomGeneratorVisitor.java:461) +Constructor (java.time.Duration)> calls constructor ()> in (RandomGeneratorVisitor.java:476) +Constructor (int)> calls constructor ()> in (RandomGeneratorVisitor.java:491) Constructor (long, long)> calls constructor (long, long)> in (SequenceGeneratorVisitor.java:207) Constructor (long, long)> calls constructor (long, long)> in (SequenceGeneratorVisitor.java:216) Constructor (org.apache.flink.streaming.api.functions.source.datagen.DataGenerator, org.apache.flink.util.function.SerializableFunction, float)> has generic parameter type > with type argument depending on in (DataGeneratorMapper.java:0) @@ -54,9 +54,9 @@ Constructor ([Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;, java.util.List, float)> depends on component type in (RowDataGenerator.java:0) Constructor ([Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;, java.util.List, float)> has parameter of type <[Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;> in (RowDataGenerator.java:0) Constructor (org.apache.flink.core.fs.Path, long, org.apache.flink.api.common.serialization.BulkWriter$Factory, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner, org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy, org.apache.flink.connector.file.sink.writer.FileWriterBucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has parameter of type in (FileSink.java:0) -Constructor (org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.BulkWriter$Factory, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)> calls method in (FileSink.java:554) +Constructor (org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.BulkWriter$Factory, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)> calls method in (FileSink.java:548) Constructor (org.apache.flink.core.fs.Path, long, org.apache.flink.api.common.serialization.Encoder, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy, org.apache.flink.connector.file.sink.writer.FileWriterBucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has parameter of type in (FileSink.java:0) -Constructor (org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.Encoder, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)> calls method in (FileSink.java:372) +Constructor (org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.Encoder, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)> calls method in (FileSink.java:366) Constructor (java.lang.String, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable)> has parameter of type in (FileSinkCommittable.java:0) Constructor (java.lang.String, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)> has parameter of type in (FileSinkCommittable.java:0) Constructor (java.lang.String, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable, org.apache.flink.core.fs.Path)> has parameter of type in (FileSinkCommittable.java:0) @@ -65,16 +65,27 @@ Constructor (org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter type > with type argument depending on in (FileSinkCommittableSerializer.java:0) Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (FileCommitter.java:0) Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (FileCommitter.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter type > with type argument depending on in (CompactCoordinator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer)> has parameter of type in (CompactCoordinator.java:0) Constructor (org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.util.function.SerializableSupplierWithException)> calls constructor ()> in (CompactCoordinatorFactory.java:49) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactCoordinatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactCoordinatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer)> has parameter of type in (CompactCoordinatorStateHandler.java:0) Constructor (org.apache.flink.util.function.SerializableSupplierWithException)> calls constructor ()> in (CompactCoordinatorStateHandlerFactory.java:50) Constructor (int, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (CompactService.java:0) Constructor (int, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactService.java:0) -Constructor (org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (CompactorOperator.java:0) -Constructor (org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (CompactorOperator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type >> with type argument depending on in (CompactorOperator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type >> with type argument depending on in (CompactorOperator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperator.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperator.java:0) Constructor (org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.util.function.SerializableSupplierWithException, org.apache.flink.util.function.SerializableSupplierWithException)> calls constructor ()> in (CompactorOperatorFactory.java:58) Constructor (org.apache.flink.connector.file.sink.compactor.FileCompactStrategy, org.apache.flink.connector.file.sink.compactor.FileCompactor, org.apache.flink.util.function.SerializableSupplierWithException, org.apache.flink.util.function.SerializableSupplierWithException)> has generic parameter type , java.io.IOException>> with type argument depending on in (CompactorOperatorFactory.java:0) -Constructor (org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (CompactorOperatorStateHandler.java:0) -Constructor (org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type > with type argument depending on in (CompactorOperatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type >> with type argument depending on in (CompactorOperatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has generic parameter type >> with type argument depending on in (CompactorOperatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperatorStateHandler.java:0) +Constructor (org.apache.flink.streaming.api.operators.StreamOperatorParameters, org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has parameter of type in (CompactorOperatorStateHandler.java:0) Constructor (org.apache.flink.util.function.SerializableSupplierWithException, org.apache.flink.util.function.SerializableSupplierWithException)> calls constructor ()> in (CompactorOperatorStateHandlerFactory.java:54) Constructor (org.apache.flink.util.function.SerializableSupplierWithException, org.apache.flink.util.function.SerializableSupplierWithException)> has generic parameter type , java.io.IOException>> with type argument depending on in (CompactorOperatorStateHandlerFactory.java:0) Constructor (org.apache.flink.core.fs.Path, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner, org.apache.flink.connector.file.sink.writer.FileWriterBucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig, org.apache.flink.api.common.operators.ProcessingTimeService, long)> has generic parameter type > with type argument depending on in (FileWriter.java:0) @@ -95,14 +106,12 @@ Constructor ([Lorg.apache.flink.core.fs.Path;, org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider, org.apache.flink.connector.file.src.reader.BulkFormat, org.apache.flink.connector.file.src.ContinuousEnumerationSettings)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in (AbstractFileSource.java:0) Constructor ([Lorg.apache.flink.core.fs.Path;, org.apache.flink.connector.file.src.reader.BulkFormat)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0) Constructor ([Lorg.apache.flink.core.fs.Path;, org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider, org.apache.flink.connector.file.src.reader.BulkFormat, org.apache.flink.connector.file.src.ContinuousEnumerationSettings)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0) -Constructor ([Lorg.apache.flink.core.fs.Path;, org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider, org.apache.flink.connector.file.src.reader.BulkFormat, org.apache.flink.connector.file.src.ContinuousEnumerationSettings, org.apache.flink.connector.file.src.FileSource$1)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0) Constructor (java.util.Collection)> calls constructor ()> in (LocalityAwareSplitAssigner.java:80) Constructor (java.util.Collection)> calls constructor ()> in (LocalityAwareSplitAssigner.java:81) Constructor (org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.file.src.enumerate.FileEnumerator, org.apache.flink.connector.file.src.assigners.FileSplitAssigner, [Lorg.apache.flink.core.fs.Path;, java.util.Collection, long)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in (ContinuousFileSplitEnumerator.java:0) Constructor (org.apache.flink.table.data.columnar.ColumnarRowData, java.lang.Runnable)> has parameter of type in (ColumnarRowIterator.java:0) Constructor ()> calls constructor (java.lang.String, java.lang.String)> in (FileSystemOutputFormat.java:235) Constructor (org.apache.flink.connector.file.table.FileSystemFactory, org.apache.flink.connector.file.table.TableMetaStoreFactory, boolean, boolean, org.apache.flink.core.fs.Path, [Ljava.lang.String;, boolean, java.util.LinkedHashMap, org.apache.flink.connector.file.table.OutputFormatFactory, org.apache.flink.connector.file.table.PartitionComputer, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig, org.apache.flink.table.catalog.ObjectIdentifier, org.apache.flink.connector.file.table.PartitionCommitPolicyFactory)> has parameter of type in (FileSystemOutputFormat.java:0) -Constructor (org.apache.flink.connector.file.table.FileSystemFactory, org.apache.flink.connector.file.table.TableMetaStoreFactory, boolean, boolean, org.apache.flink.core.fs.Path, [Ljava.lang.String;, boolean, java.util.LinkedHashMap, org.apache.flink.connector.file.table.OutputFormatFactory, org.apache.flink.connector.file.table.PartitionComputer, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig, org.apache.flink.table.catalog.ObjectIdentifier, org.apache.flink.connector.file.table.PartitionCommitPolicyFactory, org.apache.flink.connector.file.table.FileSystemOutputFormat$1)> has parameter of type in (FileSystemOutputFormat.java:0) Constructor (org.apache.flink.connector.file.table.FileSystemFactory, org.apache.flink.core.fs.Path, int, int)> calls constructor (java.lang.String, java.lang.String)> in (PartitionTempFileManager.java:71) Constructor (org.apache.flink.connector.file.table.FileSystemFactory, org.apache.flink.core.fs.Path, int, int, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has parameter of type in (PartitionTempFileManager.java:0) Constructor (java.lang.String, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, [Ljava.lang.String;)> has parameter of type <[Lorg.apache.flink.table.types.DataType;> in (RowDataPartitionComputer.java:0) @@ -118,8 +127,6 @@ Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter)> has generic parameter type > with type argument depending on in (CompactBucketWriter.java:0) Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter)> has parameter of type in (CompactBucketWriter.java:0) Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter)> has parameter of type in (CompactBucketWriter.java:0) -Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter, org.apache.flink.connector.file.table.stream.compact.CompactBucketWriter$1)> has parameter of type in (CompactBucketWriter.java:0) -Constructor (org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter, org.apache.flink.connector.file.table.stream.compact.CompactBucketWriter$1)> has parameter of type in (CompactBucketWriter.java:0) Constructor (long, org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink$BucketsBuilder)> has generic parameter type >> with type argument depending on in (CompactFileWriter.java:0) Constructor (long, org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink$BucketsBuilder)> has parameter of type in (CompactFileWriter.java:0) Constructor (org.apache.flink.table.connector.sink.DynamicTableSink$DataStructureConverter, java.lang.String, boolean)> calls constructor (java.lang.String, boolean)> in (PrintTableSinkFactory.java:173) @@ -218,9 +225,9 @@ Method calls method in (RandomGeneratorVisitor.java:218) Method calls method in (RandomGeneratorVisitor.java:219) Method calls method in (RandomGeneratorVisitor.java:338) -Method calls method in (RandomGeneratorVisitor.java:402) -Method calls method in (RandomGeneratorVisitor.java:371) -Method calls method in (RandomGeneratorVisitor.java:369) +Method calls method in (RandomGeneratorVisitor.java:405) +Method calls method in (RandomGeneratorVisitor.java:372) +Method calls method in (RandomGeneratorVisitor.java:370) Method calls method in (RandomGeneratorVisitor.java:204) Method calls method in (RandomGeneratorVisitor.java:206) Method calls method in (RandomGeneratorVisitor.java:314) @@ -251,37 +258,37 @@ Method Method calls method in (RowDataGenerator.java:54) Method calls method in (RowDataGenerator.java:61) Method has return type in (FileSink.java:0) -Method calls constructor (org.apache.flink.core.fs.RecoverableWriter, org.apache.flink.api.common.serialization.BulkWriter$Factory)> in (FileSink.java:709) +Method calls constructor (org.apache.flink.core.fs.RecoverableWriter, org.apache.flink.api.common.serialization.BulkWriter$Factory)> in (FileSink.java:694) Method has return type in (FileSink.java:0) Method calls method in (FileSink.java:634) Method calls method in (FileSink.java:635) Method calls method in (FileSink.java:636) -Method calls method in (FileSink.java:692) -Method calls method in (FileSink.java:693) -Method calls method in (FileSink.java:693) -Method calls method in (FileSink.java:692) -Method calls method in (FileSink.java:682) -Method calls method in (FileSink.java:683) -Method calls method in (FileSink.java:682) -Method calls method in (FileSink.java:683) +Method calls method in (FileSink.java:688) +Method calls method in (FileSink.java:689) +Method calls method in (FileSink.java:689) +Method calls method in (FileSink.java:688) +Method calls method in (FileSink.java:678) +Method calls method in (FileSink.java:679) +Method calls method in (FileSink.java:678) +Method calls method in (FileSink.java:679) Method has parameter of type in (FileSink.java:0) -Method calls constructor (org.apache.flink.core.fs.RecoverableWriter, org.apache.flink.api.common.serialization.Encoder)> in (FileSink.java:497) +Method calls constructor (org.apache.flink.core.fs.RecoverableWriter, org.apache.flink.api.common.serialization.Encoder)> in (FileSink.java:491) Method has return type in (FileSink.java:0) -Method calls method in (FileSink.java:437) -Method calls method in (FileSink.java:438) -Method calls method in (FileSink.java:439) -Method calls method in (FileSink.java:491) -Method calls method in (FileSink.java:492) -Method calls method in (FileSink.java:492) -Method calls method in (FileSink.java:491) -Method calls method in (FileSink.java:481) -Method calls method in (FileSink.java:482) -Method calls method in (FileSink.java:481) -Method calls method in (FileSink.java:482) +Method calls method in (FileSink.java:431) +Method calls method in (FileSink.java:432) +Method calls method in (FileSink.java:433) +Method calls method in (FileSink.java:485) +Method calls method in (FileSink.java:486) +Method calls method in (FileSink.java:486) +Method calls method in (FileSink.java:485) +Method calls method in (FileSink.java:475) +Method calls method in (FileSink.java:476) +Method calls method in (FileSink.java:475) +Method calls method in (FileSink.java:476) Method has parameter of type in (FileSink.java:0) -Method calls method in (FileSink.java:248) -Method calls method in (FileSink.java:260) -Method calls method in (FileSink.java:292) +Method calls method in (FileSink.java:242) +Method calls method in (FileSink.java:254) +Method calls method in (FileSink.java:286) Method has generic parameter type >> with type argument depending on in (FileSink.java:0) Method has generic return type >> with type argument depending on in (FileSink.java:0) Method has return type in (FileSinkCommittable.java:0) @@ -293,37 +300,31 @@ Method calls method in (FileCommitter.java:62) Method calls method in (FileCommitter.java:66) Method calls method in (FileCommitter.java:62) -Method calls method in (CompactCoordinator.java:230) -Method calls method in (CompactCoordinator.java:237) -Method calls constructor (java.lang.Object)> in (CompactCoordinator.java:147) -Method calls constructor (java.lang.Object)> in (CompactCoordinator.java:139) -Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactCoordinator.java:192) -Method calls method in (CompactCoordinator.java:93) -Method calls method in (CompactCoordinator.java:89) +Method calls method in (CompactCoordinator.java:233) +Method calls method in (CompactCoordinator.java:240) +Method calls constructor (java.lang.Object)> in (CompactCoordinator.java:150) +Method calls constructor (java.lang.Object)> in (CompactCoordinator.java:142) +Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactCoordinator.java:195) +Method calls method in (CompactCoordinator.java:96) Method calls method in (CompactCoordinator.java:92) -Method checks instanceof in (CompactCoordinator.java:90) +Method calls method in (CompactCoordinator.java:95) +Method checks instanceof in (CompactCoordinator.java:93) Method has generic parameter type >> with type argument depending on in (CompactCoordinator.java:0) Method has generic parameter type >> with type argument depending on in (CompactCoordinator.java:0) Method has parameter of type in (CompactCoordinator.java:0) -Method calls method in (CompactCoordinatorFactory.java:68) -Method calls method in (CompactCoordinatorFactory.java:61) -Method calls method in (CompactCoordinatorFactory.java:63) -Method calls method in (CompactCoordinatorFactory.java:62) -Method calls method in (CompactCoordinatorFactory.java:68) +Method calls method in (CompactCoordinatorFactory.java:65) +Method calls method in (CompactCoordinatorFactory.java:65) Method has generic parameter type > with type argument depending on in (CompactCoordinatorFactory.java:0) Method has parameter of type in (CompactCoordinatorFactory.java:0) -Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactCoordinatorStateHandler.java:73) -Method calls constructor (java.lang.Object)> in (CompactCoordinatorStateHandler.java:94) -Method calls constructor (java.lang.Object)> in (CompactCoordinatorStateHandler.java:60) -Method calls method in (CompactCoordinatorStateHandler.java:60) +Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactCoordinatorStateHandler.java:78) +Method calls constructor (java.lang.Object)> in (CompactCoordinatorStateHandler.java:99) +Method calls constructor (java.lang.Object)> in (CompactCoordinatorStateHandler.java:65) +Method calls method in (CompactCoordinatorStateHandler.java:65) Method has generic parameter type >> with type argument depending on in (CompactCoordinatorStateHandler.java:0) Method has generic parameter type >> with type argument depending on in (CompactCoordinatorStateHandler.java:0) Method has parameter of type in (CompactCoordinatorStateHandler.java:0) -Method calls method in (CompactCoordinatorStateHandlerFactory.java:78) -Method calls method in (CompactCoordinatorStateHandlerFactory.java:71) -Method calls method in (CompactCoordinatorStateHandlerFactory.java:73) -Method calls method in (CompactCoordinatorStateHandlerFactory.java:72) -Method calls method in (CompactCoordinatorStateHandlerFactory.java:78) +Method calls method in (CompactCoordinatorStateHandlerFactory.java:75) +Method calls method in (CompactCoordinatorStateHandlerFactory.java:75) Method has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactCoordinatorStateHandlerFactory.java:0) Method has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactCoordinatorStateHandlerFactory.java:0) Method has parameter of type in (CompactCoordinatorStateHandlerFactory.java:0) @@ -333,7 +334,7 @@ Method calls method in (CompactService.java:120) Method gets field in (CompactService.java:115) Method gets field in (CompactService.java:110) -Method references method in (CompactService.java:111) +Method references method in (CompactService.java:114) Method calls method in (CompactService.java:151) Method calls method in (CompactService.java:151) Method calls method in (CompactService.java:144) @@ -341,81 +342,74 @@ Method gets field in (CompactService.java:169) Method has return type in (CompactService.java:0) Method calls method in (CompactService.java:70) -Method calls constructor ([B)> in (CompactorOperator.java:299) -Method calls method in (CompactorOperator.java:323) -Method calls method in (CompactorOperator.java:326) +Method calls constructor ([B)> in (CompactorOperator.java:307) +Method calls method in (CompactorOperator.java:331) +Method calls method in (CompactorOperator.java:334) Method has parameter of type in (CompactorOperator.java:0) -Method calls constructor (int)> in (CompactorOperator.java:290) -Method calls method in (CompactorOperator.java:293) -Method calls method in (CompactorOperator.java:291) -Method calls method in (CompactorOperator.java:313) -Method calls method in (CompactorOperator.java:315) +Method calls constructor (int)> in (CompactorOperator.java:298) +Method calls method in (CompactorOperator.java:301) +Method calls method in (CompactorOperator.java:299) +Method calls method in (CompactorOperator.java:321) +Method calls method in (CompactorOperator.java:323) Method has parameter of type in (CompactorOperator.java:0) -Method calls constructor (int, int, long, int, int, int)> in (CompactorOperator.java:252) -Method calls constructor (java.lang.Object, long, int)> in (CompactorOperator.java:260) -Method calls constructor (java.lang.Object)> in (CompactorOperator.java:254) -Method calls constructor (java.lang.Object)> in (CompactorOperator.java:261) -Method calls method in (CompactorOperator.java:248) -Method calls method in (CompactorOperator.java:249) -Method calls method in (CompactorOperator.java:260) +Method calls constructor (int, int, long, int, int)> in (CompactorOperator.java:260) +Method calls constructor (java.lang.Object, long, int)> in (CompactorOperator.java:268) +Method calls constructor (java.lang.Object)> in (CompactorOperator.java:262) +Method calls constructor (java.lang.Object)> in (CompactorOperator.java:269) +Method calls method in (CompactorOperator.java:257) +Method calls method in (CompactorOperator.java:258) +Method calls method in (CompactorOperator.java:268) Method is annotated with in (CompactorOperator.java:0) -Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactorOperator.java:185) -Method calls method in (CompactorOperator.java:133) +Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactorOperator.java:192) +Method calls method in (CompactorOperator.java:139) Method has generic parameter type > with type argument depending on in (CompactorOperator.java:0) Method has parameter of type in (CompactorOperator.java:0) -Method calls method in (CompactorOperatorFactory.java:84) -Method calls method in (CompactorOperatorFactory.java:77) -Method calls method in (CompactorOperatorFactory.java:79) -Method calls method in (CompactorOperatorFactory.java:78) -Method calls method in (CompactorOperatorFactory.java:84) +Method calls method in (CompactorOperatorFactory.java:81) +Method calls method in (CompactorOperatorFactory.java:81) Method has generic parameter type >> with type argument depending on in (CompactorOperatorFactory.java:0) Method has generic parameter type >> with type argument depending on in (CompactorOperatorFactory.java:0) Method has parameter of type in (CompactorOperatorFactory.java:0) Method has type parameter 'T' depending on in (CompactorOperatorFactory.java:0) -Method calls constructor (int, int, long, int, int, int)> in (CompactorOperatorStateHandler.java:177) -Method calls constructor (java.lang.Object, long, int)> in (CompactorOperatorStateHandler.java:184) -Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:177) -Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:184) -Method calls method in (CompactorOperatorStateHandler.java:174) -Method calls method in (CompactorOperatorStateHandler.java:183) -Method calls method in (CompactorOperatorStateHandler.java:175) -Method calls method in (CompactorOperatorStateHandler.java:177) -Method calls method in (CompactorOperatorStateHandler.java:176) -Method calls method in (CompactorOperatorStateHandler.java:173) -Method calls method in (CompactorOperatorStateHandler.java:172) -Method calls method in (CompactorOperatorStateHandler.java:184) +Method calls constructor (int, int, long, int, int)> in (CompactorOperatorStateHandler.java:179) +Method calls constructor (java.lang.Object, long, int)> in (CompactorOperatorStateHandler.java:186) +Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:179) +Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:186) +Method calls method in (CompactorOperatorStateHandler.java:177) +Method calls method in (CompactorOperatorStateHandler.java:185) +Method calls method in (CompactorOperatorStateHandler.java:178) +Method calls method in (CompactorOperatorStateHandler.java:179) +Method calls method in (CompactorOperatorStateHandler.java:176) +Method calls method in (CompactorOperatorStateHandler.java:175) +Method calls method in (CompactorOperatorStateHandler.java:186) Method has generic parameter type > with type argument depending on in (CompactorOperatorStateHandler.java:0) Method has parameter of type in (CompactorOperatorStateHandler.java:0) -Method calls constructor (java.lang.Object, long, int)> in (CompactorOperatorStateHandler.java:218) -Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:218) -Method calls method in (CompactorOperatorStateHandler.java:207) -Method calls method in (CompactorOperatorStateHandler.java:196) -Method calls method in (CompactorOperatorStateHandler.java:218) +Method calls constructor (java.lang.Object, long, int)> in (CompactorOperatorStateHandler.java:220) +Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:220) +Method calls method in (CompactorOperatorStateHandler.java:209) +Method calls method in (CompactorOperatorStateHandler.java:198) +Method calls method in (CompactorOperatorStateHandler.java:220) Method has generic parameter type > with type argument depending on in (CompactorOperatorStateHandler.java:0) Method has parameter of type in (CompactorOperatorStateHandler.java:0) -Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactorOperatorStateHandler.java:87) -Method calls method in (CompactorOperatorStateHandler.java:90) -Method calls method in (CompactorOperatorStateHandler.java:189) -Method calls method in (CompactorOperatorStateHandler.java:190) +Method calls constructor (org.apache.flink.api.common.state.ListState, org.apache.flink.core.io.SimpleVersionedSerializer)> in (CompactorOperatorStateHandler.java:90) +Method calls method in (CompactorOperatorStateHandler.java:93) Method calls method in (CompactorOperatorStateHandler.java:191) -Method calls method in (CompactorOperatorStateHandler.java:190) -Method calls method in (CompactorOperatorStateHandler.java:191) +Method calls method in (CompactorOperatorStateHandler.java:192) +Method calls method in (CompactorOperatorStateHandler.java:193) +Method calls method in (CompactorOperatorStateHandler.java:192) +Method calls method in (CompactorOperatorStateHandler.java:193) Method has generic parameter type > with type argument depending on in (CompactorOperatorStateHandler.java:0) Method has parameter of type in (CompactorOperatorStateHandler.java:0) -Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:142) -Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:146) -Method calls method in (CompactorOperatorStateHandler.java:134) -Method calls method in (CompactorOperatorStateHandler.java:153) -Method checks instanceof in (CompactorOperatorStateHandler.java:138) +Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:145) +Method calls constructor (java.lang.Object)> in (CompactorOperatorStateHandler.java:149) +Method calls method in (CompactorOperatorStateHandler.java:137) +Method calls method in (CompactorOperatorStateHandler.java:156) +Method checks instanceof in (CompactorOperatorStateHandler.java:141) Method has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactorOperatorStateHandler.java:0) Method has generic parameter type , org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest>>> with type argument depending on in (CompactorOperatorStateHandler.java:0) Method has parameter of type in (CompactorOperatorStateHandler.java:0) -Method calls method in (CompactorOperatorStateHandler.java:275) -Method calls method in (CompactorOperatorStateHandlerFactory.java:75) -Method calls method in (CompactorOperatorStateHandlerFactory.java:68) -Method calls method in (CompactorOperatorStateHandlerFactory.java:70) -Method calls method in (CompactorOperatorStateHandlerFactory.java:69) -Method calls method in (CompactorOperatorStateHandlerFactory.java:75) +Method calls method in (CompactorOperatorStateHandler.java:277) +Method calls method in (CompactorOperatorStateHandlerFactory.java:73) +Method calls method in (CompactorOperatorStateHandlerFactory.java:73) Method has generic parameter type >> with type argument depending on in (CompactorOperatorStateHandlerFactory.java:0) Method has generic parameter type >> with type argument depending on in (CompactorOperatorStateHandlerFactory.java:0) Method has parameter of type in (CompactorOperatorStateHandlerFactory.java:0) @@ -536,6 +530,7 @@ Method calls method in (FileSystemTableSink.java:249) Method calls method in (FileSystemTableSink.java:253) Method calls method in (FileSystemTableSink.java:244) +Method calls constructor (java.util.Collection, org.apache.flink.api.common.typeutils.TypeSerializer)> in (FileSystemTableSource.java:131) Method calls method in (FileSystemTableSource.java:328) Method has return type <[Lorg.apache.flink.core.fs.Path;> in (FileSystemTableSource.java:0) Method references method in (FileSystemTableSource.java:295) @@ -556,7 +551,7 @@ Method calls method in (BatchSink.java:120) Method has generic parameter type >> with type argument depending on in (BatchSink.java:0) Method has parameter of type in (BatchSink.java:0) -Method references method in (BatchSink.java:100) +Method references method in (BatchSink.java:103) Method calls method in (BatchSink.java:70) Method calls method in (BatchSink.java:73) Method calls method in (BatchCompactCoordinator.java:124) @@ -573,47 +568,47 @@ Method calls method in (BatchCompactOperator.java:94) Method has generic parameter type > with type argument depending on in (BatchCompactOperator.java:0) Method has parameter of type in (BatchCompactOperator.java:0) -Method calls constructor (java.lang.Object)> in (BatchFileWriter.java:100) -Method calls method in (BatchFileWriter.java:92) -Method calls method in (BatchFileWriter.java:92) -Method calls method in (BatchFileWriter.java:88) -Method calls method in (BatchFileWriter.java:89) -Method calls method in (BatchFileWriter.java:92) -Method calls method in (BatchFileWriter.java:116) +Method calls constructor (java.lang.Object)> in (BatchFileWriter.java:98) +Method calls method in (BatchFileWriter.java:90) +Method calls method in (BatchFileWriter.java:90) +Method calls method in (BatchFileWriter.java:86) +Method calls method in (BatchFileWriter.java:87) +Method calls method in (BatchFileWriter.java:90) +Method calls method in (BatchFileWriter.java:114) Method has generic parameter type > with type argument depending on in (BatchFileWriter.java:0) Method has parameter of type in (BatchFileWriter.java:0) -Method calls method in (AbstractStreamingWriter.java:125) +Method calls method in (AbstractStreamingWriter.java:123) Method has generic parameter type > with type argument depending on in (AbstractStreamingWriter.java:0) Method has parameter of type in (AbstractStreamingWriter.java:0) -Method calls method in (AbstractStreamingWriter.java:130) +Method calls method in (AbstractStreamingWriter.java:128) Method has generic parameter type > with type argument depending on in (AbstractStreamingWriter.java:0) Method has parameter of type in (AbstractStreamingWriter.java:0) -Method calls method in (AbstractStreamingWriter.java:213) -Method calls method in (AbstractStreamingWriter.java:109) -Method calls method in (AbstractStreamingWriter.java:202) -Method calls method in (AbstractStreamingWriter.java:203) -Method calls constructor (org.apache.flink.streaming.api.functions.sink.filesystem.Buckets, boolean, org.apache.flink.api.common.state.OperatorStateStore, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService, long)> in (AbstractStreamingWriter.java:141) -Method calls method in (AbstractStreamingWriter.java:164) -Method calls method in (AbstractStreamingWriter.java:120) -Method calls method in (AbstractStreamingWriter.java:134) -Method calls method in (AbstractStreamingWriter.java:116) -Method calls method in (AbstractStreamingWriter.java:141) -Method calls method in (AbstractStreamingWriter.java:117) -Method calls method in (AbstractStreamingWriter.java:183) -Method calls method in (AbstractStreamingWriter.java:186) -Method calls method in (AbstractStreamingWriter.java:184) -Method calls method in (AbstractStreamingWriter.java:186) -Method calls method in (AbstractStreamingWriter.java:185) +Method calls method in (AbstractStreamingWriter.java:211) +Method calls method in (AbstractStreamingWriter.java:107) +Method calls method in (AbstractStreamingWriter.java:200) +Method calls method in (AbstractStreamingWriter.java:201) +Method calls constructor (org.apache.flink.streaming.api.functions.sink.filesystem.Buckets, boolean, org.apache.flink.api.common.state.OperatorStateStore, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService, long)> in (AbstractStreamingWriter.java:139) +Method calls method in (AbstractStreamingWriter.java:162) +Method calls method in (AbstractStreamingWriter.java:118) +Method calls method in (AbstractStreamingWriter.java:132) +Method calls method in (AbstractStreamingWriter.java:114) +Method calls method in (AbstractStreamingWriter.java:139) +Method calls method in (AbstractStreamingWriter.java:115) +Method calls method in (AbstractStreamingWriter.java:181) +Method calls method in (AbstractStreamingWriter.java:184) +Method calls method in (AbstractStreamingWriter.java:182) +Method calls method in (AbstractStreamingWriter.java:184) +Method calls method in (AbstractStreamingWriter.java:183) Method has generic parameter type > with type argument depending on in (AbstractStreamingWriter.java:0) Method has parameter of type in (AbstractStreamingWriter.java:0) -Method calls method in (AbstractStreamingWriter.java:171) +Method calls method in (AbstractStreamingWriter.java:169) Method has parameter of type in (PartitionCommitTrigger.java:0) Method calls method in (PartitionCommitter.java:167) Method calls method in (PartitionCommitter.java:172) Method calls method in (PartitionCommitter.java:140) Method has generic parameter type > with type argument depending on in (PartitionCommitter.java:0) Method has parameter of type in (PartitionCommitter.java:0) -Method calls method in (PartitionTimeCommitPredicate.java:70) +Method calls method in (PartitionTimeCommitPredicate.java:71) Method calls method in (ProcTimeCommitTrigger.java:111) Method calls method in (ProcTimeCommitTrigger.java:76) Method calls method in (StreamingFileWriter.java:130) @@ -627,7 +622,7 @@ Method calls method in (StreamingSink.java:142) Method has generic parameter type >> with type argument depending on in (StreamingSink.java:0) Method has parameter of type in (StreamingSink.java:0) -Method references method in (StreamingSink.java:127) +Method references method in (StreamingSink.java:130) Method calls method in (StreamingSink.java:80) Method has generic parameter type >> with type argument depending on in (StreamingSink.java:0) Method has parameter of type in (StreamingSink.java:0) @@ -672,14 +667,14 @@ Method calls method in (PrintTableSinkFactory.java:178) Method calls method in (PrintTableSinkFactory.java:181) Method calls method in (PrintTableSinkFactory.java:182) -Static Initializer ()> gets field in (CompactCoordinator.java:67) -Static Initializer ()> gets field in (CompactorOperator.java:83) +Static Initializer ()> gets field in (CompactCoordinator.java:68) +Static Initializer ()> gets field in (CompactorOperator.java:85) Static Initializer ()> calls constructor (int)> in (FileSourceSplitSerializer.java:42) Static Initializer ()> calls method in (StandardDeCompressors.java:45) Static Initializer ()> calls method in (StandardDeCompressors.java:43) Static Initializer ()> calls method in (StandardDeCompressors.java:44) Static Initializer ()> calls method in (StandardDeCompressors.java:46) -Static Initializer ()> gets field in (AbstractStreamingWriter.java:74) +Static Initializer ()> gets field in (AbstractStreamingWriter.java:73) Static Initializer ()> calls constructor (org.apache.flink.api.common.typeutils.TypeSerializer)> in (PartitionTimeCommitTrigger.java:52) Static Initializer ()> calls constructor (org.apache.flink.api.common.typeutils.TypeSerializer, org.apache.flink.api.common.typeutils.TypeSerializer)> in (PartitionTimeCommitTrigger.java:56) Static Initializer ()> gets field in (PartitionTimeCommitTrigger.java:56)