(flink) branch master updated: [FLINK-35454] Allow connector classes to depend on internal Flink util classes

[jingge]

This is an automated email from the ASF dual-hosted git repository.

jingge pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new b1025e66e7b [FLINK-35454] Allow connector classes to depend on 
internal Flink util classes
b1025e66e7b is described below

commit b1025e66e7b13bce6a6407544420dc494cd5e1b2
Author: Ahmed Hamdy <ahmed.ha...@ververica.com>
AuthorDate: Sun May 26 09:43:20 2024 +0100

    [FLINK-35454] Allow connector classes to depend on internal Flink util 
classes
---
 .../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e           | 186 ---------------------
 .../flink/architecture/rules/ConnectorRules.java   |   7 +-
 2 files changed, 6 insertions(+), 187 deletions(-)

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 1ee0876bc43..0e90559119d 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
@@ -32,51 +32,13 @@ Class 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator
 Class 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory>
 has generic superclass 
<org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.flink.connector.file.sink.FileSinkCommittable>>>
 with type argument depending on 
<org.apache.flink.streaming.api.connector.sink2.CommittableMessage> in 
(CompactorOperatorStateHandlerFactory.java:0)
 Class 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory>
 implements interface 
<org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory> in 
(CompactorOperatorStateHandlerFactory.java:0)
 Class <org.apache.flink.connector.file.table.stream.AbstractStreamingWriter$1> 
implements interface 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketLifeCycleListener>
 in (AbstractStreamingWriter.java:0)
-Constructor 
<org.apache.flink.connector.base.sink.AsyncSinkBase.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 int, int, int, long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (AsyncSinkBase.java:67)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AsyncSinkWriter.java:269)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AsyncSinkWriter.java:270)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AsyncSinkWriter.java:271)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AsyncSinkWriter.java:272)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AsyncSinkWriter.java:273)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (AsyncSinkWriter.java:274)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (AsyncSinkWriter.java:278)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AsyncSinkWriter.java:268)
-Constructor 
<org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.<init>(org.apache.flink.connector.base.sink.writer.ElementConverter,
 org.apache.flink.api.connector.sink2.Sink$InitContext, 
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AsyncSinkWriter.java:282)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.AIMDScalingStrategy.<init>(int,
 double, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (AIMDScalingStrategy.java:34)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.AIMDScalingStrategy.<init>(int,
 double, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (AIMDScalingStrategy.java:35)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.AIMDScalingStrategy.<init>(int,
 double, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (AIMDScalingStrategy.java:38)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.CongestionControlRateLimitingStrategy.<init>(int,
 int, org.apache.flink.connector.base.sink.writer.strategy.ScalingStrategy)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CongestionControlRateLimitingStrategy.java:48)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.CongestionControlRateLimitingStrategy.<init>(int,
 int, org.apache.flink.connector.base.sink.writer.strategy.ScalingStrategy)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CongestionControlRateLimitingStrategy.java:50)
-Constructor 
<org.apache.flink.connector.base.sink.writer.strategy.CongestionControlRateLimitingStrategy.<init>(int,
 int, org.apache.flink.connector.base.sink.writer.strategy.ScalingStrategy)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (CongestionControlRateLimitingStrategy.java:53)
-Constructor 
<org.apache.flink.connector.base.source.hybrid.HybridSource$SourceListEntry.<init>(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory,
 org.apache.flink.api.connector.source.Boundedness)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(HybridSource.java:211)
-Constructor 
<org.apache.flink.connector.base.source.hybrid.HybridSource$SourceListEntry.<init>(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory,
 org.apache.flink.api.connector.source.Boundedness)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(HybridSource.java:212)
-Constructor 
<org.apache.flink.connector.base.source.hybrid.HybridSource.<init>(java.util.List)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(HybridSource.java:96)
-Constructor 
<org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 java.util.List, int, 
org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(HybridSourceSplitEnumerator.java:89)
-Constructor 
<org.apache.flink.connector.base.source.reader.RecordsBySplits.<init>(java.util.Map,
 java.util.Set)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (RecordsBySplits.java:50)
-Constructor 
<org.apache.flink.connector.base.source.reader.RecordsBySplits.<init>(java.util.Map,
 java.util.Set)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (RecordsBySplits.java:51)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.PauseOrResumeSplitsTask.<init>(org.apache.flink.connector.base.source.reader.splitreader.SplitReader,
 java.util.Collection, java.util.Collection, boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PauseOrResumeSplitsTask.java:54)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.PauseOrResumeSplitsTask.<init>(org.apache.flink.connector.base.source.reader.splitreader.SplitReader,
 java.util.Collection, java.util.Collection, boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PauseOrResumeSplitsTask.java:55)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.PauseOrResumeSplitsTask.<init>(org.apache.flink.connector.base.source.reader.splitreader.SplitReader,
 java.util.Collection, java.util.Collection, boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PauseOrResumeSplitsTask.java:56)
 Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.<init>(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 java.util.function.Supplier, org.apache.flink.configuration.Configuration, 
java.util.function.Consumer)> is annotated with 
<org.apache.flink.annotation.VisibleForTesting> in 
(SingleThreadFetcherManager.java:0)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.<init>(int, 
org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 org.apache.flink.connector.base.source.reader.splitreader.SplitReader, 
java.util.function.Consumer, java.lang.Runnable, java.util.function.Consumer, 
boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SplitFetcher.java:94)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.<init>(int, 
org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 org.apache.flink.connector.base.source.reader.splitreader.SplitReader, 
java.util.function.Consumer, java.lang.Runnable, java.util.function.Consumer, 
boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SplitFetcher.java:95)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.<init>(int, 
org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 org.apache.flink.connector.base.source.reader.splitreader.SplitReader, 
java.util.function.Consumer, java.lang.Runnable, java.util.function.Consumer, 
boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SplitFetcher.java:96)
-Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.<init>(int, 
org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 org.apache.flink.connector.base.source.reader.splitreader.SplitReader, 
java.util.function.Consumer, java.lang.Runnable, java.util.function.Consumer, 
boolean)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SplitFetcher.java:97)
 Constructor 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.<init>(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue,
 java.util.function.Supplier, org.apache.flink.configuration.Configuration, 
java.util.function.Consumer)> is annotated with 
<org.apache.flink.annotation.VisibleForTesting> in (SplitFetcherManager.java:0)
-Constructor 
<org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue.<init>(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FutureCompletingBlockingQueue.java:114)
 Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory,
 org.apache.flink.connector.datagen.source.GeneratorFunction, long, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, 
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in 
(DataGeneratorSource.java:155)
 Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory,
 org.apache.flink.connector.datagen.source.GeneratorFunction, long, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, 
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in 
(DataGeneratorSource.java:157)
-Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory,
 org.apache.flink.connector.datagen.source.GeneratorFunction, long, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DataGeneratorSource.java:150)
-Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory,
 org.apache.flink.connector.datagen.source.GeneratorFunction, long, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DataGeneratorSource.java:151)
-Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory,
 org.apache.flink.connector.datagen.source.GeneratorFunction, long, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DataGeneratorSource.java:152)
 Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy.noOp()>
 in (DataGeneratorSource.java:120)
 Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 long, 
org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy, 
org.apache.flink.api.common.typeinfo.TypeInformation)> calls method 
<org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, 
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in 
(DataGeneratorSource.java:141)
 Constructor 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 long, 
org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy, 
org.apache.flink.api.common.typeinfo.TypeInformation)> has parameter of type 
<org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy> in 
(DataGeneratorSource.java:0)
-Constructor 
<org.apache.flink.connector.datagen.source.DoubleEmittingSourceReaderWithCheckpointsInBetween.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.connector.datagen.source.GeneratorFunction)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DoubleEmittingSourceReaderWithCheckpointsInBetween.java:73)
-Constructor 
<org.apache.flink.connector.datagen.source.DoubleEmittingSourceReaderWithCheckpointsInBetween.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.connector.datagen.source.GeneratorFunction, 
java.util.function.BooleanSupplier)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DoubleEmittingSourceReaderWithCheckpointsInBetween.java:66)
-Constructor 
<org.apache.flink.connector.datagen.source.GeneratingIteratorSourceReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.connector.datagen.source.GeneratorFunction)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(GeneratingIteratorSourceReader.java:46)
-Constructor 
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(GeneratorSourceReaderFactory.java:54)
-Constructor 
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(GeneratorSourceReaderFactory.java:55)
 Constructor 
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction,
 org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy)> has 
parameter of type 
<org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy> in 
(GeneratorSourceReaderFactory.java:0)
 Constructor 
<org.apache.flink.connector.datagen.table.DataGenTableSource.<init>([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)> depends on component type 
<org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in 
(DataGenTableSource.java:0)
 Constructor 
<org.apache.flink.connector.datagen.table.DataGenTableSource.<init>([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)
@@ -89,43 +51,21 @@ Constructor 
<org.apache.flink.connector.datagen.table.SequenceGeneratorVisitor$1
 Constructor 
<org.apache.flink.connector.datagen.table.SequenceGeneratorVisitor$2.<init>(long,
 long)> calls constructor 
<org.apache.flink.streaming.api.functions.source.datagen.SequenceGenerator.<init>(long,
 long)> in (SequenceGeneratorVisitor.java:216)
 Constructor 
<org.apache.flink.connector.datagen.table.types.DataGeneratorMapper.<init>(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator,
 org.apache.flink.util.function.SerializableFunction, float)> has generic 
parameter type 
<org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<A>> with 
type argument depending on 
<org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in 
(DataGeneratorMapper.java:0)
 Constructor 
<org.apache.flink.connector.datagen.table.types.DataGeneratorMapper.<init>(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator,
 org.apache.flink.util.function.SerializableFunction, float)> has parameter of 
type <org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in 
(DataGeneratorMapper.java:0)
-Constructor 
<org.apache.flink.connector.datagen.table.types.DecimalDataRandomGenerator.<init>(int,
 int, double, double, float)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(DecimalDataRandomGenerator.java:49)
 Constructor 
<org.apache.flink.connector.datagen.table.types.RowDataGenerator.<init>([Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;,
 java.util.List, float)> depends on component type 
<org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in 
(RowDataGenerator.java:0)
 Constructor 
<org.apache.flink.connector.datagen.table.types.RowDataGenerator.<init>([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.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
 Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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.OutputFileCo [...]
 Constructor 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.<init>(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 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.builder()>
 in (FileSink.java:533)
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
-Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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)> 
calls method <org.apache.flink. [...]
 Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(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 <org.apac [...]
 Constructor 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.<init>(org.apache.flink.core.fs.Path,
 org.apache.flink.api.common.serialization.Encoder, 
org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)> calls 
method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.builder()>
 in (FileSink.java:355)
-Constructor 
<org.apache.flink.connector.file.sink.FileSink.<init>(org.apache.flink.connector.file.sink.FileSink$BucketsBuilder)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:140)
-Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(java.lang.String,
 org.apache.flink.core.fs.Path)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSinkCommittable.java:68)
-Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(java.lang.String,
 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSinkCommittable.java:60)
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(java.lang.String,
 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>
 in (FileSinkCommittable.java:0)
-Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(java.lang.String,
 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSinkCommittable.java:50)
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(java.lang.String,
 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>
 in (FileSinkCommittable.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(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 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>
 in (FileSinkCommittable.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittable.<init>(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 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>
 in (FileSinkCommittable.java:0)
-Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittableSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSinkCommittableSerializer.java:53)
-Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittableSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSinkCommittableSerializer.java:54)
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittableSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter 
type 
<org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>>
 with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InPr
 [...]
 Constructor 
<org.apache.flink.connector.file.sink.FileSinkCommittableSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter 
type 
<org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>>
 with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$Pending
 [...]
-Constructor 
<org.apache.flink.connector.file.sink.committer.FileCommitter.<init>(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileCommitter.java:52)
 Constructor 
<org.apache.flink.connector.file.sink.committer.FileCommitter.<init>(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)>
 has generic parameter type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?, ?>> 
with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(FileCommitter.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.committer.FileCommitter.<init>(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(FileCommitter.java:0)
-Constructor 
<org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.<init>(org.apache.flink.core.fs.Path,
 org.apache.flink.connector.file.sink.compactor.DecoderBasedReader$Decoder)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DecoderBasedReader.java:40)
-Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.<init>(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.core.io.SimpleVersionedSerializer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(CompactCoordinator.java:83)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorFactory.<init>(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.util.function.SerializableSupplierWithException)> calls 
constructor 
<org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory.<init>()>
 in (CompactCoordinatorFactory.java:49)
-Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandler.<init>(org.apache.flink.core.io.SimpleVersionedSerializer)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(CompactCoordinatorStateHandler.java:54)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandlerFactory.<init>(org.apache.flink.util.function.SerializableSupplierWithException)>
 calls constructor 
<org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory.<init>()>
 in (CompactCoordinatorStateHandlerFactory.java:50)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.<init>(int,
 org.apache.flink.connector.file.sink.compactor.FileCompactor, 
org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has 
generic parameter type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?, 
java.lang.String>> with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(CompactService.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.<init>(int,
 org.apache.flink.connector.file.sink.compactor.FileCompactor, 
org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(CompactService.java:0)
@@ -137,23 +77,9 @@ Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOp
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(CompactorOperatorStateHandler.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory.<init>(org.apache.flink.util.function.SerializableSupplierWithException,
 org.apache.flink.util.function.SerializableSupplierWithException)> calls 
constructor 
<org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory.<init>()>
 in (CompactorOperatorStateHandlerFactory.java:54)
 Constructor 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory.<init>(org.apache.flink.util.function.SerializableSupplierWithException,
 org.apache.flink.util.function.SerializableSupplierWithException)> has generic 
parameter type 
<org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,
 java.lang.String>, java.io.IOException>> with type argument depending on 
<org.ap [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriter.<init>(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. [...]
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:91)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:92)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:93)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:94)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:95)
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> has 
generic parameter type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN, 
java.lang.String>> with type argument dep [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(FileWriterBucket.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, 
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)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(FileWriterBucket.java:0)
@@ -163,57 +89,20 @@ Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.<init>
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketState.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, long, 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>
 in (FileWriterBucketState.java:0)
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketState.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, long, 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable,
 java.util.Map)> has generic parameter type <java.util.Map<java.lang.Long, 
java.util.List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>>>
 with type argument depending on <org.apache.flink.str [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketState.<init>(java.lang.String,
 org.apache.flink.core.fs.Path, long, 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable,
 java.util.Map)> has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>
 in (FileWriterBucketState.java:0)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucketStateSerializer.java:68)
-Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucketStateSerializer.java:69)
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter 
type 
<org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable>>
 with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWr [...]
 Constructor 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer,
 org.apache.flink.core.io.SimpleVersionedSerializer)> has generic parameter 
type 
<org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>>
 with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWrite 
[...]
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.<init>([Lorg.apache.flink.core.fs.Path;,
 org.apache.flink.connector.file.src.reader.BulkFormat, 
org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:274)
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.<init>([Lorg.apache.flink.core.fs.Path;,
 org.apache.flink.connector.file.src.reader.BulkFormat, 
org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:275)
 Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.<init>([Lorg.apache.flink.core.fs.Path;,
 org.apache.flink.connector.file.src.reader.BulkFormat, 
org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> has 
parameter of type <[Lorg.apache.flink.core.fs.Path;> in 
(AbstractFileSource.java:0)
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource.<init>([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)> calls 
method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractFileSource.java:91)
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource.<init>([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)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:93)
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource.<init>([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)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:94)
-Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource.<init>([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)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:95)
 Constructor 
<org.apache.flink.connector.file.src.AbstractFileSource.<init>([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 
<org.apache.flink.connector.file.src.ContinuousEnumerationSettings.<init>(java.time.Duration)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(ContinuousEnumerationSettings.java:40)
 Constructor 
<org.apache.flink.connector.file.src.FileSource$FileSourceBuilder.<init>([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 
<org.apache.flink.connector.file.src.FileSource.<init>([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 
<org.apache.flink.connector.file.src.FileSource.<init>([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 
<org.apache.flink.connector.file.src.FileSourceSplit.<init>(java.lang.String, 
org.apache.flink.core.fs.Path, long, long, long, long, [Ljava.lang.String;, 
org.apache.flink.connector.file.src.util.CheckpointedPosition, [B)> calls 
method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileSourceSplit.java:213)
-Constructor 
<org.apache.flink.connector.file.src.FileSourceSplit.<init>(java.lang.String, 
org.apache.flink.core.fs.Path, long, long, long, long, [Ljava.lang.String;, 
org.apache.flink.connector.file.src.util.CheckpointedPosition, [B)> calls 
method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileSourceSplit.java:214)
-Constructor 
<org.apache.flink.connector.file.src.FileSourceSplit.<init>(java.lang.String, 
org.apache.flink.core.fs.Path, long, long, long, long, [Ljava.lang.String;, 
org.apache.flink.connector.file.src.util.CheckpointedPosition, [B)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSourceSplit.java:217)
-Constructor 
<org.apache.flink.connector.file.src.FileSourceSplit.<init>(java.lang.String, 
org.apache.flink.core.fs.Path, long, long, long, long, [Ljava.lang.String;, 
org.apache.flink.connector.file.src.util.CheckpointedPosition, [B)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSourceSplit.java:218)
-Constructor 
<org.apache.flink.connector.file.src.FileSourceSplitState.<init>(org.apache.flink.connector.file.src.FileSourceSplit)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSourceSplitState.java:47)
-Constructor 
<org.apache.flink.connector.file.src.PendingSplitsCheckpointSerializer.<init>(org.apache.flink.core.io.SimpleVersionedSerializer)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PendingSplitsCheckpointSerializer.java:47)
 Constructor 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.<init>(java.util.Collection)>
 calls constructor <org.apache.flink.metrics.SimpleCounter.<init>()> in 
(LocalityAwareSplitAssigner.java:80)
 Constructor 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.<init>(java.util.Collection)>
 calls constructor <org.apache.flink.metrics.SimpleCounter.<init>()> in 
(LocalityAwareSplitAssigner.java:81)
-Constructor 
<org.apache.flink.connector.file.src.enumerate.BlockSplittingRecursiveEnumerator.<init>(java.util.function.Predicate,
 [Ljava.lang.String;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(BlockSplittingRecursiveEnumerator.java:85)
-Constructor 
<org.apache.flink.connector.file.src.enumerate.NonSplittingRecursiveEnumerator.<init>(java.util.function.Predicate)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(NonSplittingRecursiveEnumerator.java:71)
-Constructor 
<org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator.<init>(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)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(ContinuousFileSplitEnumerator.java:80)
-Constructor 
<org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator.<init>(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)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(ContinuousFileSplitEnumerator.java:81)
-Constructor 
<org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator.<init>(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)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(ContinuousFileSplitEnumerator.java:82)
-Constructor 
<org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator.<init>(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)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(ContinuousFileSplitEnumerator.java:83)
 Constructor 
<org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator.<init>(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.connector.file.src.impl.DynamicFileSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 org.apache.flink.connector.file.src.enumerate.DynamicFileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DynamicFileSplitEnumerator.java:92)
-Constructor 
<org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 org.apache.flink.connector.file.src.enumerate.DynamicFileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DynamicFileSplitEnumerator.java:93)
-Constructor 
<org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 org.apache.flink.connector.file.src.enumerate.DynamicFileEnumerator$Provider, 
org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(DynamicFileSplitEnumerator.java:94)
-Constructor 
<org.apache.flink.connector.file.src.impl.FileRecordFormatAdapter$Reader.<init>(org.apache.flink.connector.file.src.reader.FileRecordFormat$Reader,
 int, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (FileRecordFormatAdapter.java:149)
-Constructor 
<org.apache.flink.connector.file.src.impl.FileRecordFormatAdapter$Reader.<init>(org.apache.flink.connector.file.src.reader.FileRecordFormat$Reader,
 int, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileRecordFormatAdapter.java:150)
-Constructor 
<org.apache.flink.connector.file.src.impl.StaticFileSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 org.apache.flink.connector.file.src.assigners.FileSplitAssigner)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(StaticFileSplitEnumerator.java:66)
-Constructor 
<org.apache.flink.connector.file.src.impl.StaticFileSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 org.apache.flink.connector.file.src.assigners.FileSplitAssigner)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(StaticFileSplitEnumerator.java:67)
-Constructor 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter$Reader.<init>(org.apache.flink.connector.file.src.reader.StreamFormat$Reader,
 
org.apache.flink.connector.file.src.impl.StreamFormatAdapter$TrackingFsDataInputStream,
 long, long)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(StreamFormatAdapter.java:200)
-Constructor 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter$Reader.<init>(org.apache.flink.connector.file.src.reader.StreamFormat$Reader,
 
org.apache.flink.connector.file.src.impl.StreamFormatAdapter$TrackingFsDataInputStream,
 long, long)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(StreamFormatAdapter.java:201)
-Constructor 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter$TrackingFsDataInputStream.<init>(org.apache.flink.core.fs.FSDataInputStream,
 long, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(StreamFormatAdapter.java:264)
-Constructor 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter.<init>(org.apache.flink.connector.file.src.reader.StreamFormat)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(StreamFormatAdapter.java:62)
-Constructor 
<org.apache.flink.connector.file.src.util.CheckpointedPosition.<init>(long, 
long)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CheckpointedPosition.java:61)
-Constructor 
<org.apache.flink.connector.file.src.util.CheckpointedPosition.<init>(long, 
long)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CheckpointedPosition.java:62)
 Constructor 
<org.apache.flink.connector.file.table.ColumnarRowIterator.<init>(org.apache.flink.table.data.columnar.ColumnarRowData,
 java.lang.Runnable)> has parameter of type 
<org.apache.flink.table.data.columnar.ColumnarRowData> in 
(ColumnarRowIterator.java:0)
 Constructor 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.<init>()> 
calls constructor 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.<init>(java.lang.String,
 java.lang.String)> in (FileSystemOutputFormat.java:216)
 Constructor 
<org.apache.flink.connector.file.table.FileSystemOutputFormat.<init>(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 [...]
 Constructor 
<org.apache.flink.connector.file.table.FileSystemOutputFormat.<init>(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 [...]
-Constructor 
<org.apache.flink.connector.file.table.FileSystemTableSink$TableRollingPolicy.<init>(boolean,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(FileSystemTableSink.java:593)
-Constructor 
<org.apache.flink.connector.file.table.FileSystemTableSink$TableRollingPolicy.<init>(boolean,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(FileSystemTableSink.java:594)
-Constructor 
<org.apache.flink.connector.file.table.FileSystemTableSink$TableRollingPolicy.<init>(boolean,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(FileSystemTableSink.java:595)
 Constructor 
<org.apache.flink.connector.file.table.PartitionTempFileManager.<init>(org.apache.flink.connector.file.table.FileSystemFactory,
 org.apache.flink.core.fs.Path, int, int)> calls constructor 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.<init>(java.lang.String,
 java.lang.String)> in (PartitionTempFileManager.java:71)
 Constructor 
<org.apache.flink.connector.file.table.PartitionTempFileManager.<init>(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 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(PartitionTempFileManager.java:0)
 Constructor 
<org.apache.flink.connector.file.table.RowDataPartitionComputer.<init>(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)
@@ -284,25 +173,13 @@ Field 
<org.apache.flink.connector.file.table.stream.compact.CompactBucketWriter$
 Field 
<org.apache.flink.connector.file.table.stream.compact.CompactBucketWriter.bucketWriter>
 has type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(CompactBucketWriter.java:0)
 Field 
<org.apache.flink.connector.file.table.stream.compact.CompactBucketWriter.writer>
 has type 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter> 
in (CompactBucketWriter.java:0)
 Field 
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.writer>
 has type <org.apache.flink.api.common.functions.util.PrintSinkOutputWriter> in 
(PrintTableSinkFactory.java:0)
-Method 
<org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier.withRootCauseOfType(java.lang.Class,
 java.util.function.Function)> calls method 
<org.apache.flink.util.ExceptionUtils.findThrowable(java.lang.Throwable, 
java.lang.Class)> in (FatalExceptionClassifier.java:60)
 Method 
<org.apache.flink.connector.base.source.hybrid.HybridSource$HybridSourceBuilder.addSource(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory,
 org.apache.flink.api.connector.source.Boundedness)> calls method 
<org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, 
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in 
(HybridSource.java:246)
-Method 
<org.apache.flink.connector.base.source.hybrid.HybridSource$HybridSourceBuilder.addSource(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory,
 org.apache.flink.api.connector.source.Boundedness)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (HybridSource.java:242)
-Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceReader.addSplits(java.util.List)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (HybridSourceReader.java:153)
-Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceReader.setCurrentReader(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(HybridSourceReader.java:206)
 Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 int, int, int)> calls method 
<org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits.signalIntermediateNoMoreSplits(int)>
 in (HybridSourceSplitEnumerator.java:448)
-Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 int, int, int)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.String, 
[Ljava.lang.Object;)> in (HybridSourceSplitEnumerator.java:440)
 Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 int, int, int)> checks instanceof 
<org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits> in 
(HybridSourceSplitEnumerator.java:440)
-Method 
<org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.handleSplitRequest(int,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean)> in 
(HybridSourceSplitEnumerator.java:111)
-Method <org.apache.flink.connector.base.source.hybrid.SwitchedSources.put(int, 
org.apache.flink.api.connector.source.Source)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SwitchedSources.java:48)
-Method 
<org.apache.flink.connector.base.source.hybrid.SwitchedSources.sourceOf(int)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String, [Ljava.lang.Object;)> in (SwitchedSources.java:38)
-Method 
<org.apache.flink.connector.base.source.reader.SourceReaderBase.moveToNextSplit(org.apache.flink.connector.base.source.reader.RecordsWithSplitIds,
 org.apache.flink.api.connector.source.ReaderOutput)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(SourceReaderBase.java:229)
 Method 
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.getNumAliveFetchers()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(SplitFetcherManager.java:0)
 Method 
<org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue.take()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FutureCompletingBlockingQueue.java:0)
 Method 
<org.apache.flink.connector.datagen.functions.FromElementsGeneratorFunction.getSerializer()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FromElementsGeneratorFunction.java:0)
-Method 
<org.apache.flink.connector.datagen.functions.FromElementsGeneratorFunction.serializeElements(java.lang.Iterable)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (FromElementsGeneratorFunction.java:97)
-Method 
<org.apache.flink.connector.datagen.functions.FromElementsGeneratorFunction.setOutputType(org.apache.flink.api.common.typeinfo.TypeInformation,
 org.apache.flink.api.common.ExecutionConfig)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(FromElementsGeneratorFunction.java:151)
 Method 
<org.apache.flink.connector.datagen.functions.IndexLookupGeneratorFunction.getSerializer()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(IndexLookupGeneratorFunction.java:0)
-Method 
<org.apache.flink.connector.datagen.functions.IndexLookupGeneratorFunction.serializeElements(java.lang.Iterable)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (IndexLookupGeneratorFunction.java:128)
 Method 
<org.apache.flink.connector.datagen.source.DataGeneratorSource.getGeneratorFunction()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(DataGeneratorSource.java:0)
 Method 
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.createReader(org.apache.flink.api.connector.source.SourceReaderContext)>
 calls constructor 
<org.apache.flink.api.connector.source.util.ratelimit.RateLimitedSourceReader.<init>(org.apache.flink.api.connector.source.SourceReader,
 org.apache.flink.api.connector.source.util.ratelimit.RateLimiter)> in 
(GeneratorSourceReaderFactory.java:63)
 Method 
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.createReader(org.apache.flink.api.connector.source.SourceReaderContext)>
 calls method 
<org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy.createRateLimiter(int)>
 in (GeneratorSourceReaderFactory.java:62)
@@ -368,8 +245,6 @@ Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.createBu
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.Sink$InitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.builder()>
 in (FileSink.java:638)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.Sink$InitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartPrefix()>
 in (FileSink.java:639)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.Sink$InitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartSuffix()>
 in (FileSink.java:640)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.enableCompact(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.connector.file.sink.compactor.FileCompactor)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:590)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.enableCompact(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.connector.file.sink.compactor.FileCompactor)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:591)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:668)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:669)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getInProgressFileRecoverableSerializer()>
 in (FileSink.java:669)
@@ -378,18 +253,12 @@ Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getWrite
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:659)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getInProgressFileRecoverableSerializer()>
 in (FileSink.java:658)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getPendingFileRecoverableSerializer()>
 in (FileSink.java:659)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withBucketAssigner(org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:559)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withNewBucketAssigner(org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:583)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withNewBucketAssigner(org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (FileSink.java:575)
 Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(FileSink.java:0)
-Method 
<org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withRollingPolicy(org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:564)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createBucketWriter()>
 calls constructor 
<org.apache.flink.streaming.api.functions.sink.filesystem.RowWiseBucketWriter.<init>(org.apache.flink.core.fs.RecoverableWriter,
 org.apache.flink.api.common.serialization.Encoder)> in (FileSink.java:480)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createBucketWriter()>
 has return type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(FileSink.java:0)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.builder()>
 in (FileSink.java:435)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartPrefix()>
 in (FileSink.java:436)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartSuffix()>
 in (FileSink.java:437)
-Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.enableCompact(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.connector.file.sink.compactor.FileCompactor)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:396)
-Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.enableCompact(org.apache.flink.connector.file.sink.compactor.FileCompactStrategy,
 org.apache.flink.connector.file.sink.compactor.FileCompactor)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:397)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:474)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:475)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getCommittableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getInProgressFileRecoverableSerializer()>
 in (FileSink.java:475)
@@ -398,9 +267,7 @@ Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getWriter
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.getProperties()>
 in (FileSink.java:465)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getInProgressFileRecoverableSerializer()>
 in (FileSink.java:464)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.getWriterStateSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.WriterProperties.getPendingFileRecoverableSerializer()>
 in (FileSink.java:465)
-Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.withBucketAssigner(org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:381)
 Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.withOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(FileSink.java:0)
-Method 
<org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.withRollingPolicy(org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileSink.java:386)
 Method 
<org.apache.flink.connector.file.sink.FileSink.addPreCommitTopology(org.apache.flink.streaming.api.datastream.DataStream)>
 calls method <org.apache.flink.api.dag.Transformation.setParallelism(int, 
boolean)> in (FileSink.java:231)
 Method 
<org.apache.flink.connector.file.sink.FileSink.addPreCommitTopology(org.apache.flink.streaming.api.datastream.DataStream)>
 calls method <org.apache.flink.api.dag.Transformation.setParallelism(int, 
boolean)> in (FileSink.java:243)
 Method 
<org.apache.flink.connector.file.sink.FileSink.addPreCommitTopology(org.apache.flink.streaming.api.datastream.DataStream)>
 calls method <org.apache.flink.api.dag.Transformation.setParallelism(int, 
boolean)> in (FileSink.java:275)
@@ -415,16 +282,11 @@ Method 
<org.apache.flink.connector.file.sink.FileSinkCommittableSerializer.seria
 Method 
<org.apache.flink.connector.file.sink.committer.FileCommitter.commit(java.util.Collection)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter$PendingFile.commitAfterRecovery()>
 in (FileCommitter.java:62)
 Method 
<org.apache.flink.connector.file.sink.committer.FileCommitter.commit(java.util.Collection)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.cleanupInProgressFileRecoverable(org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable)>
 in (FileCommitter.java:66)
 Method 
<org.apache.flink.connector.file.sink.committer.FileCommitter.commit(java.util.Collection)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.recoverPendingFile(org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)>
 in (FileCommitter.java:62)
-Method 
<org.apache.flink.connector.file.sink.compactor.FileCompactStrategy$Builder.enableCompactionOnCheckpoint(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileCompactStrategy.java:76)
-Method 
<org.apache.flink.connector.file.sink.compactor.FileCompactStrategy$Builder.setNumCompactThreads(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileCompactStrategy.java:94)
-Method 
<org.apache.flink.connector.file.sink.compactor.IdenticalFileCompactor.compact(java.util.List,
 java.io.OutputStream)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(IdenticalFileCompactor.java:41)
-Method 
<org.apache.flink.connector.file.sink.compactor.OutputStreamBasedFileCompactor.compact(java.util.List,
 java.io.OutputStream)> calls constructor 
<org.apache.flink.util.CloseShieldOutputStream.<init>(java.io.OutputStream)> in 
(OutputStreamBasedFileCompactor.java:37)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator$CompactTrigger.onElement(org.apache.flink.connector.file.sink.FileSinkCommittable)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable.getPath()>
 in (CompactCoordinator.java:230)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator$CompactTrigger.onElement(org.apache.flink.connector.file.sink.FileSinkCommittable)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable.getSize()>
 in (CompactCoordinator.java:237)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.endInput()>
 calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (CompactCoordinator.java:147)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.fireAndPurge(java.lang.String)>
 calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (CompactCoordinator.java:139)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
 calls constructor 
<org.apache.flink.streaming.api.operators.util.SimpleVersionedListState.<init>(org.apache.flink.api.common.state.ListState,
 org.apache.flink.core.io.SimpleVersionedSerializer)> in 
(CompactCoordinator.java:192)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.packAndTrigger(org.apache.flink.connector.file.sink.FileSinkCommittable)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(CompactCoordinator.java:107)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage.getCommittable()>
 in (CompactCoordinator.java:93)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.getValue()> in 
(CompactCoordinator.java:89)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.getValue()> in 
(CompactCoordinator.java:92)
@@ -464,12 +326,9 @@ Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.c
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter$PendingFile.commitAfterRecovery()>
 in (CompactService.java:151)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.recoverPendingFile(org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)>
 in (CompactService.java:151)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable.getPath()>
 in (CompactService.java:144)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (CompactService.java:141)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (CompactService.java:145)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getWriterType(org.apache.flink.connector.file.sink.compactor.FileCompactor)>
 gets field 
<org.apache.flink.streaming.api.functions.sink.filesystem.CompactingFileWriter$Type.OUTPUT_STREAM>
 in (CompactService.java:167)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getWriterType(org.apache.flink.connector.file.sink.compactor.FileCompactor)>
 gets field 
<org.apache.flink.streaming.api.functions.sink.filesystem.CompactingFileWriter$Type.RECORD_WISE>
 in (CompactService.java:169)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.getWriterType(org.apache.flink.connector.file.sink.compactor.FileCompactor)>
 has return type 
<org.apache.flink.streaming.api.functions.sink.filesystem.CompactingFileWriter$Type>
 in (CompactService.java:0)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.open()> 
calls constructor 
<org.apache.flink.util.concurrent.ExecutorThreadFactory.<init>(java.lang.String)>
 in (CompactService.java:70)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactService.open()> 
calls method <org.apache.flink.runtime.util.Hardware.getNumberCPUCores()> in 
(CompactService.java:70)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator$RemainingRequestsSerializer.deserialize(int,
 [B)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(CompactorOperator.java:301)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator$RemainingRequestsSerializer.deserializeV1(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(CompactorOperator.java:325)
@@ -521,7 +380,6 @@ Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperato
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (CompactorOperatorStateHandler.java:218)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 calls method 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage.getCommittable()>
 in (CompactorOperatorStateHandler.java:196)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 calls method 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage.getSubtaskId()>
 in (CompactorOperatorStateHandler.java:218)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (CompactorOperatorStateHandler.java:211)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 has generic parameter type 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage<org.apache.flink.connector.file.sink.FileSinkCommittable>>
 with type argument depending on 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage> in 
(CompactorOperatorStateHandler.java:0)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.handleHiddenCommittable(org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage)>
 has parameter of type 
<org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage> in 
(CompactorOperatorStateHandler.java:0)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
 calls constructor 
<org.apache.flink.streaming.api.operators.util.SimpleVersionedListState.<init>(org.apache.flink.api.common.state.ListState,
 org.apache.flink.core.io.SimpleVersionedSerializer)> in 
(CompactorOperatorStateHandler.java:87)
@@ -551,7 +409,6 @@ Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperato
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters)>
 has generic parameter type 
<org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.flink.connector.file.sink.FileSinkCommittable>>>
 with type argument depending on 
<org.apache.flink.streaming.api.operators.StreamOp [...]
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters)>
 has parameter of type 
<org.apache.flink.streaming.api.operators.StreamOperatorParameters> in 
(CompactorOperatorStateHandlerFactory.java:0)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters)>
 has type parameter 'T' depending on 
<org.apache.flink.streaming.api.connector.sink2.CommittableMessage> in 
(CompactorOperatorStateHandlerFactory.java:0)
-Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest.addToCompact(org.apache.flink.connector.file.sink.FileSinkCommittable)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(CompactorRequest.java:54)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestSerializer.deserialize(int,
 [B)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(CompactorRequestSerializer.java:60)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestSerializer.deserializeV1(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readUTF()> in 
(CompactorRequestSerializer.java:81)
 Method 
<org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestSerializer.deserializeV1(org.apache.flink.core.memory.DataInputDeserializer)>
 has parameter of type <org.apache.flink.core.memory.DataInputDeserializer> in 
(CompactorRequestSerializer.java:0)
@@ -568,8 +425,6 @@ Method 
<org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFacto
 Method 
<org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory.restoreBucket(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter,
 org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy, 
org.apache.flink.connector.file.sink.writer.FileWriterBucketState, 
org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter> in 
(DefaultFile [...]
 Method 
<org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory.restoreBucket(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter,
 org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy, 
org.apache.flink.connector.file.sink.writer.FileWriterBucketState, 
org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has 
parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(Default [...]
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriter.getActiveBuckets()> is 
annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FileWriter.java:0)
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriter.initializeState(java.util.Collection)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileWriter.java:159)
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriter.snapshotState(long)> 
calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (FileWriter.java:230)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.assembleNewPartPath()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartPrefix()>
 in (FileWriterBucket.java:269)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.assembleNewPartPath()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartSuffix()>
 in (FileWriterBucket.java:274)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.closePartFile()> 
calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.closeForCommit()>
 in (FileWriterBucket.java:280)
@@ -582,8 +437,6 @@ Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.getNew(java
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.getPendingFiles()>
 has generic return type 
<java.util.List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>>
 with type argument depending on 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable>
 in (FileWriterBucket.java:0)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.getPendingFiles()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FileWriterBucket.java:0)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.getUniqueId()> is 
annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FileWriterBucket.java:0)
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.merge(org.apache.flink.connector.file.sink.writer.FileWriterBucket)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(FileWriterBucket.java:169)
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.merge(org.apache.flink.connector.file.sink.writer.FileWriterBucket)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(FileWriterBucket.java:170)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.onProcessingTime(long)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.getCreationTime()>
 in (FileWriterBucket.java:240)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.onProcessingTime(long)>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.getLastUpdateTime()>
 in (FileWriterBucket.java:241)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucket.restore(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter,
 org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy, 
org.apache.flink.connector.file.sink.writer.FileWriterBucketState, 
org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)> has 
generic parameter type 
<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN, 
java.lang.String>> with typ [...]
@@ -610,26 +463,14 @@ Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSeriali
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.deserializeV1(org.apache.flink.core.memory.DataInputView)>
 calls constructor 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedPendingFileRecoverable.<init>(org.apache.flink.core.fs.RecoverableWriter$CommitRecoverable)>
 in (FileWriterBucketStateSerializer.java:138)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.getCommitableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedPendingFileRecoverableSerializer.getCommitSerializer()>
 in (FileWriterBucketStateSerializer.java:236)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.getResumableSerializer()>
 calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedInProgressFileRecoverableSerializer.getResumeSerializer()>
 in (FileWriterBucketStateSerializer.java:226)
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.internalDeserialize(org.apache.flink.core.memory.DataInputView,
 org.apache.flink.util.function.FunctionWithException, 
org.apache.flink.util.function.BiFunctionWithException)> calls method 
<org.apache.flink.util.function.BiFunctionWithException.apply(java.lang.Object, 
java.lang.Object)> in (FileWriterBucketStateSerializer.java:196)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.internalDeserialize(org.apache.flink.core.memory.DataInputView,
 org.apache.flink.util.function.FunctionWithException, 
org.apache.flink.util.function.BiFunctionWithException)> has generic parameter 
type <org.apache.flink.util.function.BiFunctionWithException<java.lang.Integer, 
byte[], 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable,
 java.io.IOException>> [...]
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.internalDeserialize(org.apache.flink.core.memory.DataInputView,
 org.apache.flink.util.function.FunctionWithException, 
org.apache.flink.util.function.BiFunctionWithException)> has generic parameter 
type <org.apache.flink.util.function.BiFunctionWithException<java.lang.Integer, 
byte[], 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable,
 java.io.IOException>> [...]
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.internalDeserialize(org.apache.flink.core.memory.DataInputView,
 org.apache.flink.util.function.FunctionWithException, 
org.apache.flink.util.function.BiFunctionWithException)> has generic parameter 
type 
<org.apache.flink.util.function.FunctionWithException<org.apache.flink.core.memory.DataInputView,
 
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable,
 jav [...]
-Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.internalDeserialize(org.apache.flink.core.memory.DataInputView,
 org.apache.flink.util.function.FunctionWithException, 
org.apache.flink.util.function.BiFunctionWithException)> has parameter of type 
<org.apache.flink.util.function.BiFunctionWithException> in 
(FileWriterBucketStateSerializer.java:0)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.serialize(org.apache.flink.connector.file.sink.writer.FileWriterBucketState)>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(FileWriterBucketStateSerializer.java:79)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.serialize(org.apache.flink.connector.file.sink.writer.FileWriterBucketState)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getCopyOfBuffer()> in 
(FileWriterBucketStateSerializer.java:82)
 Method 
<org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer.serialize(org.apache.flink.connector.file.sink.writer.FileWriterBucketState)>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (FileWriterBucketStateSerializer.java:80)
-Method 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.monitorContinuously(java.time.Duration)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (AbstractFileSource.java:297)
-Method 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.monitorContinuously(java.time.Duration)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (AbstractFileSource.java:296)
-Method 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.setFileEnumerator(org.apache.flink.connector.file.src.enumerate.FileEnumerator$Provider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:326)
-Method 
<org.apache.flink.connector.file.src.AbstractFileSource$AbstractFileSourceBuilder.setSplitAssigner(org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractFileSource.java:336)
-Method 
<org.apache.flink.connector.file.src.FileSource.forBulkFileFormat(org.apache.flink.connector.file.src.reader.BulkFormat,
 [Lorg.apache.flink.core.fs.Path;)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (FileSource.java:175)
-Method 
<org.apache.flink.connector.file.src.FileSource.forBulkFileFormat(org.apache.flink.connector.file.src.reader.BulkFormat,
 [Lorg.apache.flink.core.fs.Path;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSource.java:173)
-Method 
<org.apache.flink.connector.file.src.FileSource.forBulkFileFormat(org.apache.flink.connector.file.src.reader.BulkFormat,
 [Lorg.apache.flink.core.fs.Path;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSource.java:174)
 Method 
<org.apache.flink.connector.file.src.FileSource.forBulkFileFormat(org.apache.flink.connector.file.src.reader.BulkFormat,
 [Lorg.apache.flink.core.fs.Path;)> has parameter of type 
<[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0)
 Method 
<org.apache.flink.connector.file.src.FileSource.forRecordFileFormat(org.apache.flink.connector.file.src.reader.FileRecordFormat,
 [Lorg.apache.flink.core.fs.Path;)> has parameter of type 
<[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0)
 Method 
<org.apache.flink.connector.file.src.FileSource.forRecordStreamFormat(org.apache.flink.connector.file.src.reader.StreamFormat,
 [Lorg.apache.flink.core.fs.Path;)> has parameter of type 
<[Lorg.apache.flink.core.fs.Path;> in (FileSource.java:0)
-Method 
<org.apache.flink.connector.file.src.FileSourceSplit.checkNoNullHosts([Ljava.lang.String;)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileSourceSplit.java:312)
-Method 
<org.apache.flink.connector.file.src.FileSourceSplit.checkNoNullHosts([Ljava.lang.String;)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSourceSplit.java:310)
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
 calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(FileSourceSplitSerializer.java:100)
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
 calls method 
<org.apache.flink.core.memory.DataInputDeserializer.readBoolean()> in 
(FileSourceSplitSerializer.java:112)
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readLong()> 
in (FileSourceSplitSerializer.java:105)
@@ -648,21 +489,12 @@ Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeLong(long)> in 
(FileSourceSplitSerializer.java:77)
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeLong(long)> in 
(FileSourceSplitSerializer.java:78)
 Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeUTF(java.lang.String)> 
in (FileSourceSplitSerializer.java:66)
-Method 
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (FileSourceSplitSerializer.java:55)
-Method 
<org.apache.flink.connector.file.src.PendingSplitsCheckpoint.fromCollectionSnapshot(java.util.Collection)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PendingSplitsCheckpoint.java:90)
-Method 
<org.apache.flink.connector.file.src.PendingSplitsCheckpoint.fromCollectionSnapshot(java.util.Collection,
 java.util.Collection)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(PendingSplitsCheckpoint.java:99)
-Method 
<org.apache.flink.connector.file.src.PendingSplitsCheckpointSerializer.serialize(org.apache.flink.connector.file.src.PendingSplitsCheckpoint)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (PendingSplitsCheckpointSerializer.java:59)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNext(java.lang.String)>
 calls method <org.apache.flink.metrics.SimpleCounter.inc()> in 
(LocalityAwareSplitAssigner.java:114)
-Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNext(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (LocalityAwareSplitAssigner.java:107)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfLocalAssignments()>
 calls method <org.apache.flink.metrics.SimpleCounter.getCount()> in 
(LocalityAwareSplitAssigner.java:156)
-Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfLocalAssignments()>
 calls method <org.apache.flink.util.MathUtils.checkedDownCast(long)> in 
(LocalityAwareSplitAssigner.java:156)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfLocalAssignments()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(LocalityAwareSplitAssigner.java:0)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfRemoteAssignments()>
 calls method <org.apache.flink.metrics.SimpleCounter.getCount()> in 
(LocalityAwareSplitAssigner.java:161)
-Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfRemoteAssignments()>
 calls method <org.apache.flink.util.MathUtils.checkedDownCast(long)> in 
(LocalityAwareSplitAssigner.java:161)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getNumberOfRemoteAssignments()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(LocalityAwareSplitAssigner.java:0)
 Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getRemoteSplit()>
 calls method <org.apache.flink.metrics.SimpleCounter.inc()> in 
(LocalityAwareSplitAssigner.java:150)
-Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.getRemoteSplit()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (LocalityAwareSplitAssigner.java:147)
-Method 
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner.normalizeHostName(java.lang.String)>
 calls method 
<org.apache.flink.util.NetUtils.getHostnameFromFQDN(java.lang.String)> in 
(LocalityAwareSplitAssigner.java:167)
 Method 
<org.apache.flink.connector.file.src.compression.StandardDeCompressors.buildDecompressorMap([Lorg.apache.flink.api.common.io.compression.InflaterInputStreamFactory;)>
 calls method 
<org.apache.flink.api.common.io.compression.InflaterInputStreamFactory.getCommonFileExtensions()>
 in (StandardDeCompressors.java:91)
 Method 
<org.apache.flink.connector.file.src.compression.StandardDeCompressors.buildDecompressorMap([Lorg.apache.flink.api.common.io.compression.InflaterInputStreamFactory;)>
 depends on component type 
<org.apache.flink.api.common.io.compression.InflaterInputStreamFactory> in 
(StandardDeCompressors.java:0)
 Method 
<org.apache.flink.connector.file.src.compression.StandardDeCompressors.buildDecompressorMap([Lorg.apache.flink.api.common.io.compression.InflaterInputStreamFactory;)>
 has generic return type <java.util.Map<java.lang.String, 
org.apache.flink.api.common.io.compression.InflaterInputStreamFactory<?>>> with 
type argument depending on 
<org.apache.flink.api.common.io.compression.InflaterInputStreamFactory> in 
(StandardDeCompressors.java:0)
@@ -673,27 +505,15 @@ Method 
<org.apache.flink.connector.file.src.enumerate.BlockSplittingRecursiveEnu
 Method 
<org.apache.flink.connector.file.src.enumerate.FileEnumerator.enumerateSplits([Lorg.apache.flink.core.fs.Path;,
 int)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in 
(FileEnumerator.java:0)
 Method 
<org.apache.flink.connector.file.src.enumerate.NonSplittingRecursiveEnumerator.enumerateSplits([Lorg.apache.flink.core.fs.Path;,
 int)> has parameter of type <[Lorg.apache.flink.core.fs.Path;> in 
(NonSplittingRecursiveEnumerator.java:0)
 Method 
<org.apache.flink.connector.file.src.enumerate.NonSplittingRecursiveEnumerator.getHostsFromBlockLocations([Lorg.apache.flink.core.fs.BlockLocation;)>
 has parameter of type <[Lorg.apache.flink.core.fs.BlockLocation;> in 
(NonSplittingRecursiveEnumerator.java:0)
-Method 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter$Reader.close()> 
calls method 
<org.apache.flink.util.IOUtils.closeQuietly(java.lang.AutoCloseable)> in 
(StreamFormatAdapter.java:235)
 Method 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter.openStream(org.apache.flink.core.fs.Path,
 org.apache.flink.configuration.Configuration, long)> calls method 
<org.apache.flink.api.common.io.compression.InflaterInputStreamFactory.create(java.io.InputStream)>
 in (StreamFormatAdapter.java:178)
-Method 
<org.apache.flink.connector.file.src.impl.StreamFormatAdapter.openStream(org.apache.flink.core.fs.Path,
 org.apache.flink.configuration.Configuration, long)> calls method 
<org.apache.flink.util.MathUtils.checkedDownCast(long)> in 
(StreamFormatAdapter.java:160)
-Method 
<org.apache.flink.connector.file.src.reader.SimpleStreamFormat.createReader(org.apache.flink.configuration.Configuration,
 org.apache.flink.core.fs.FSDataInputStream, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.String, 
[Ljava.lang.Object;)> in (SimpleStreamFormat.java:85)
-Method 
<org.apache.flink.connector.file.src.util.Utils.doWithCleanupOnException(java.io.Closeable,
 org.apache.flink.util.function.SupplierWithException)> calls method 
<org.apache.flink.util.ExceptionUtils.rethrowIOException(java.lang.Throwable)> 
in (Utils.java:48)
-Method 
<org.apache.flink.connector.file.src.util.Utils.doWithCleanupOnException(java.io.Closeable,
 org.apache.flink.util.function.SupplierWithException)> calls method 
<org.apache.flink.util.IOUtils.closeQuietly(java.lang.AutoCloseable)> in 
(Utils.java:47)
 Method <org.apache.flink.connector.file.table.ColumnarRowIterator.next()> 
calls method 
<org.apache.flink.table.data.columnar.ColumnarRowData.setRowId(int)> in 
(ColumnarRowIterator.java:70)
 Method 
<org.apache.flink.connector.file.table.DeserializationSchemaAdapter$1.getMetricGroup()>
 calls constructor 
<org.apache.flink.metrics.groups.UnregisteredMetricsGroup.<init>()> in 
(DeserializationSchemaAdapter.java:68)
-Method 
<org.apache.flink.connector.file.table.DeserializationSchemaAdapter.createDeserialization()>
 calls method 
<org.apache.flink.util.InstantiationUtil.clone(java.io.Serializable)> in 
(DeserializationSchemaAdapter.java:63)
 Method 
<org.apache.flink.connector.file.table.DynamicPartitionWriter.write(java.lang.Object)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (DynamicPartitionWriter.java:62)
 Method 
<org.apache.flink.connector.file.table.FileInfoExtractorBulkFormat.wrapReader(org.apache.flink.connector.file.src.reader.BulkFormat$Reader,
 org.apache.flink.connector.file.src.FileSourceSplit)> calls method 
<org.apache.flink.table.utils.PartitionPathUtils.convertStringToInternalValue(java.lang.String,
 org.apache.flink.table.types.DataType)> in 
(FileInfoExtractorBulkFormat.java:156)
 Method 
<org.apache.flink.connector.file.table.FileInfoExtractorBulkFormat.wrapReader(org.apache.flink.connector.file.src.reader.BulkFormat$Reader,
 org.apache.flink.connector.file.src.FileSourceSplit)> calls method 
<org.apache.flink.table.utils.PartitionPathUtils.extractPartitionSpecFromPath(org.apache.flink.core.fs.Path)>
 in (FileInfoExtractorBulkFormat.java:140)
 Method 
<org.apache.flink.connector.file.table.FileSystemCommitter.commitPartitionsWithFiles(java.util.Map)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.extractPartitionSpecFromPath(org.apache.flink.core.fs.Path)>
 in (FileSystemCommitter.java:146)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSystemOutputFormat.java:324)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSystemOutputFormat.java:325)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSystemOutputFormat.java:326)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSystemOutputFormat.java:327)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FileSystemOutputFormat.java:328)
 Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.setOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig)>
 has parameter of type 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig> in 
(FileSystemOutputFormat.java:0)
 Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat$Builder.setStagingPath(org.apache.flink.core.fs.Path)>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(FileSystemOutputFormat.java:291)
-Method 
<org.apache.flink.connector.file.table.FileSystemOutputFormat.createStagingDirectory(org.apache.flink.core.fs.Path)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (FileSystemOutputFormat.java:109)
 Method 
<org.apache.flink.connector.file.table.FileSystemTableSink$TableBucketAssigner.getBucketId(org.apache.flink.table.data.RowData,
 
org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner$Context)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (FileSystemTableSink.java:553)
 Method 
<org.apache.flink.connector.file.table.FileSystemTableSink.createBatchSink(org.apache.flink.streaming.api.datastream.DataStream,
 org.apache.flink.table.connector.sink.DynamicTableSink$Context, int, boolean)> 
calls method <org.apache.flink.api.dag.Transformation.setParallelism(int, 
boolean)> in (FileSystemTableSink.java:208)
 Method 
<org.apache.flink.connector.file.table.FileSystemTableSink.createBatchSink(org.apache.flink.streaming.api.datastream.DataStream,
 org.apache.flink.table.connector.sink.DynamicTableSink$Context, int, boolean)> 
calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.builder()>
 in (FileSystemTableSink.java:189)
@@ -701,17 +521,14 @@ Method 
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamin
 Method 
<org.apache.flink.connector.file.table.FileSystemTableSource.listPartitions()> 
calls method 
<org.apache.flink.table.utils.PartitionPathUtils.searchPartSpecAndPaths(org.apache.flink.core.fs.FileSystem,
 org.apache.flink.core.fs.Path, int)> in (FileSystemTableSource.java:328)
 Method <org.apache.flink.connector.file.table.FileSystemTableSource.paths()> 
has return type <[Lorg.apache.flink.core.fs.Path;> in 
(FileSystemTableSource.java:0)
 Method <org.apache.flink.connector.file.table.FileSystemTableSource.paths()> 
references method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (FileSystemTableSource.java:295)
-Method 
<org.apache.flink.connector.file.table.FileSystemTableSource.wrapBulkFormat(org.apache.flink.table.connector.source.ScanTableSource$ScanContext,
 org.apache.flink.connector.file.src.reader.BulkFormat, 
org.apache.flink.table.types.DataType, java.util.List, java.util.List)> calls 
method <org.apache.flink.util.CollectionUtil.entry(java.lang.Object, 
java.lang.Object)> in (FileSystemTableSource.java:248)
 Method 
<org.apache.flink.connector.file.table.GroupedPartitionWriter.write(java.lang.Object)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (GroupedPartitionWriter.java:62)
 Method 
<org.apache.flink.connector.file.table.LimitableBulkFormat.globalNumberRead()> 
is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(LimitableBulkFormat.java:0)
 Method 
<org.apache.flink.connector.file.table.PartitionFieldExtractor.$deserializeLambda$(java.lang.invoke.SerializedLambda)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.extractPartitionSpecFromPath(org.apache.flink.core.fs.Path)>
 in (PartitionFieldExtractor.java:39)
 Method 
<org.apache.flink.connector.file.table.PartitionFieldExtractor.forFileSystem(java.lang.String)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.extractPartitionSpecFromPath(org.apache.flink.core.fs.Path)>
 in (PartitionFieldExtractor.java:39)
 Method 
<org.apache.flink.connector.file.table.PartitionLoader.loadEmptyPartition(java.util.LinkedHashMap)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (PartitionLoader.java:138)
 Method 
<org.apache.flink.connector.file.table.PartitionLoader.loadPartition(java.util.LinkedHashMap,
 java.util.List, boolean)> calls method 
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
 in (PartitionLoader.java:97)
-Method 
<org.apache.flink.connector.file.table.PartitionLoader.moveFile(org.apache.flink.core.fs.Path,
 org.apache.flink.core.fs.Path)> calls method 
<org.apache.flink.util.FileUtils.copy(org.apache.flink.core.fs.Path, 
org.apache.flink.core.fs.Path, boolean)> in (PartitionLoader.java:198)
 Method 
<org.apache.flink.connector.file.table.PartitionLoader.moveFiles(java.util.List,
 org.apache.flink.core.fs.Path, boolean)> calls method 
<org.apache.flink.table.utils.PartitionPathUtils.listStatusWithoutHidden(org.apache.flink.core.fs.FileSystem,
 org.apache.flink.core.fs.Path)> in (PartitionLoader.java:177)
 Method 
<org.apache.flink.connector.file.table.PartitionLoader.overwrite(org.apache.flink.core.fs.Path)>
 calls method 
<org.apache.flink.table.utils.PartitionPathUtils.listStatusWithoutHidden(org.apache.flink.core.fs.FileSystem,
 org.apache.flink.core.fs.Path)> in (PartitionLoader.java:159)
-Method 
<org.apache.flink.connector.file.table.PartitionLoader.overwriteAndMoveFiles(java.util.List,
 org.apache.flink.core.fs.Path, boolean)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(PartitionLoader.java:150)
 Method 
<org.apache.flink.connector.file.table.PartitionTempFileManager.collectPartSpecToPaths(org.apache.flink.core.fs.FileSystem,
 java.util.List, int)> calls method 
<org.apache.flink.table.utils.PartitionPathUtils.searchPartSpecAndPaths(org.apache.flink.core.fs.FileSystem,
 org.apache.flink.core.fs.Path, int)> in (PartitionTempFileManager.java:149)
 Method 
<org.apache.flink.connector.file.table.PartitionTempFileManager.newFileName()> 
calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartPrefix()>
 in (PartitionTempFileManager.java:108)
 Method 
<org.apache.flink.connector.file.table.PartitionTempFileManager.newFileName()> 
calls method 
<org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.getPartSuffix()>
 in (PartitionTempFileManager.java:111)
@@ -726,7 +543,6 @@ Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactCoordina
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.getValue()> in 
(BatchCompactCoordinator.java:83)
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 has generic parameter type 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.connector.file.table.stream.compact.CompactMessages$CoordinatorInput>>
 with type argument depending on 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord> in 
(BatchCompactCoordinator.java:0)
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 has parameter of type 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord> in 
(BatchCompactCoordinator.java:0)
-Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator.convertFromUncompacted(org.apache.flink.core.fs.Path)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (BatchCompactOperator.java:142)
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator.endInput()>
 calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (BatchCompactOperator.java:125)
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.runtime.execution.Environment.getTaskManagerInfo()> in 
(BatchCompactOperator.java:94)
 Method 
<org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.runtime.taskmanager.TaskManagerRuntimeInfo.getConfiguration()>
 in (BatchCompactOperator.java:94)
@@ -805,7 +621,6 @@ Method 
<org.apache.flink.connector.file.table.stream.compact.CompactFileWriter.c
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactFileWriter.commitUpToCheckpoint(long)>
 calls method 
<org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getTaskInfo()>
 in (CompactFileWriter.java:62)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactFileWriter.commitUpToCheckpoint(long)>
 calls method 
<org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getTaskInfo()>
 in (CompactFileWriter.java:63)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactFileWriter.onPartFileOpened(java.lang.String,
 org.apache.flink.core.fs.Path)> calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (CompactFileWriter.java:52)
-Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.convertFromUncompacted(org.apache.flink.core.fs.Path)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CompactOperator.java:211)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.endCompaction(long)>
 calls constructor 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
 in (CompactOperator.java:162)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.endCompaction(long)>
 calls method 
<org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getTaskInfo()>
 in (CompactOperator.java:160)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.endCompaction(long)>
 calls method 
<org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getTaskInfo()>
 in (CompactOperator.java:161)
@@ -821,7 +636,6 @@ Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.pro
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 calls method 
<org.apache.flink.streaming.runtime.tasks.StreamTask.getEnvironment()> in 
(CompactOperator.java:138)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 has generic parameter type 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.connector.file.table.stream.compact.CompactMessages$CoordinatorOutput>>
 with type argument depending on 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord> in 
(CompactOperator.java:0)
 Method 
<org.apache.flink.connector.file.table.stream.compact.CompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord)>
 has parameter of type 
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord> in 
(CompactOperator.java:0)
-Method 
<org.apache.flink.connector.file.table.utils.CompactFileUtils.doSingleFileMove(org.apache.flink.core.fs.FileSystem,
 org.apache.flink.core.fs.Path, org.apache.flink.core.fs.Path)> calls method 
<org.apache.flink.util.IOUtils.copyBytes(java.io.InputStream, 
java.io.OutputStream, boolean)> in (CompactFileUtils.java:117)
 Method 
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.invoke(org.apache.flink.table.data.RowData,
 org.apache.flink.streaming.api.functions.sink.SinkFunction$Context)> calls 
method 
<org.apache.flink.api.common.functions.util.PrintSinkOutputWriter.write(java.lang.Object)>
 in (PrintTableSinkFactory.java:189)
 Method 
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.open(org.apache.flink.api.common.functions.OpenContext)>
 calls method 
<org.apache.flink.api.common.functions.util.PrintSinkOutputWriter.open(int, 
int)> in (PrintTableSinkFactory.java:180)
 Method 
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.open(org.apache.flink.api.common.functions.OpenContext)>
 calls method 
<org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getTaskInfo()>
 in (PrintTableSinkFactory.java:181)
diff --git 
a/flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java
 
b/flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java
index bb4bec7f1cb..1ebd9c3a945 100644
--- 
a/flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java
+++ 
b/flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java
@@ -39,6 +39,8 @@ public class ConnectorRules {
         "org.apache.flink.connector..", 
"org.apache.flink.streaming.connectors.."
     };
 
+    private static final String[] UTIL_PACKAGES = {"org.apache.flink.util.."};
+
     private static DescribedPredicate<JavaClass>
             areFlinkClassesThatResideOutsideOfConnectorPackagesAndArePublic() {
         return JavaClass.Predicates.resideInAPackage("org.apache.flink..")
@@ -73,7 +75,10 @@ public class ConnectorRules {
                                                             
"org.apache.flink.."))
                                             .or(
                                                     
JavaClass.Predicates.resideInAnyPackage(
-                                                            
CONNECTOR_PACKAGES)))
+                                                            
CONNECTOR_PACKAGES))
+                                            .or(
+                                                    
JavaClass.Predicates.resideInAnyPackage(
+                                                            UTIL_PACKAGES)))
                             .as(
                                     "Connector production code must depend 
only on public API when outside of connector packages"));
 }