This is an automated email from the ASF dual-hosted git repository. 1996fanrui pushed a commit to branch release-1.20 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 73e921780b2c7e7ea65d0c108a1a820001a75aa1 Author: Rui Fan <[email protected]> AuthorDate: Sun Oct 11 21:19:18 2026 +0200 [FLINK-38613][tests] Update frozen connector violations for backport --- .../archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 6 ++++-- 1 file changed, 4 insertions(+), 2 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 dff51184be5..5986ea95b25 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 @@ -34,11 +34,13 @@ Class <org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator 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.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.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.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, org.apache.flink.api.common.typeinfo.TypeInformation, org.apache.flink.api.connector.source.lib.NumberSequenceSource)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGenerator [...] +Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, org.apache.flink.api.common.typeinfo.TypeInformation, org.apache.flink.api.connector.source.lib.NumberSequenceSource)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGenerator [...] 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.DataGeneratorSource.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction, org.apache.flink.api.connector.source.lib.NumberSequenceSource, 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 [...] +Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.connector.datagen.source.GeneratorFunction, org.apache.flink.api.connector.source.lib.NumberSequenceSource, 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.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)
