This is an automated email from the ASF dual-hosted git repository.
snuyanzin 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 00f22d1b143 [FLINK-39750][tests] Drop `FailsOnJava11`
00f22d1b143 is described below
commit 00f22d1b14350090c6855cea1696742fadce2c69
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Tue May 26 07:24:13 2026 +0200
[FLINK-39750][tests] Drop `FailsOnJava11`
---
.../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 26 +++++++++++-----------
.../flink/architecture/rules/ConnectorRules.java | 3 ---
flink-end-to-end-tests/pom.xml | 3 ---
.../flink/testutils/junit/FailsOnJava11.java | 21 -----------------
pom.xml | 22 ------------------
5 files changed, 13 insertions(+), 62 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 e8e2bdbd5cd..caac78113b2 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,12 +34,10 @@ Class
<org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator
Class
<org.apache.flink.connector.file.table.batch.compact.BatchPartitionCommitterSink>
extends class
<org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction> in
(BatchPartitionCommitterSink.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)
Class
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction>
extends class
<org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction> in
(PrintTableSinkFactory.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.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.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.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.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.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.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)
Constructor
<org.apache.flink.connector.datagen.table.DataGenVisitorBase.<init>(java.lang.String,
org.apache.flink.configuration.ReadableConfig)> calls constructor
<org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor.<init>()>
in (DataGenVisitorBase.java:49)
@@ -110,7 +108,7 @@ Constructor
<org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAss
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.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.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:235)
+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:237)
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.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)
@@ -131,7 +129,6 @@ Constructor
<org.apache.flink.connector.file.table.stream.compact.CompactFileWri
Constructor
<org.apache.flink.connector.file.table.stream.compact.CompactFileWriter.<init>(long,
org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink$BucketsBuilder)>
has parameter of type
<org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink$BucketsBuilder>
in (CompactFileWriter.java:0)
Constructor
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.<init>(org.apache.flink.table.connector.sink.DynamicTableSink$DataStructureConverter,
java.lang.String, boolean)> calls constructor
<org.apache.flink.api.common.functions.util.PrintSinkOutputWriter.<init>(java.lang.String,
boolean)> in (PrintTableSinkFactory.java:173)
Constructor
<org.apache.flink.connector.print.table.PrintTableSinkFactory$RowDataPrintFunction.<init>(org.apache.flink.table.connector.sink.DynamicTableSink$DataStructureConverter,
java.lang.String, boolean)> calls constructor
<org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction.<init>()>
in (PrintTableSinkFactory.java:171)
-Field
<org.apache.flink.connector.datagen.source.GeneratorSourceReaderFactory.rateLimiterStrategy>
has type
<org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy> in
(GeneratorSourceReaderFactory.java:0)
Field
<org.apache.flink.connector.datagen.table.DataGenTableSource.fieldGenerators>
depends on component type
<org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in
(DataGenTableSource.java:0)
Field
<org.apache.flink.connector.datagen.table.DataGenTableSource.fieldGenerators>
has type
<[Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;> in
(DataGenTableSource.java:0)
Field
<org.apache.flink.connector.datagen.table.DataGeneratorContainer.generator> has
type <org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in
(DataGeneratorContainer.java:0)
@@ -190,7 +187,7 @@ 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.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.api.java.ClosureCleaner.clean(java.lang.Object,
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in
(HybridSource.java:258)
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:450)
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:442)
Method
<org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.getNumAliveFetchers()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(SplitFetcherManager.java:0)
@@ -199,7 +196,6 @@ Method
<org.apache.flink.connector.datagen.functions.FromElementsGeneratorFuncti
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.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)
Method
<org.apache.flink.connector.datagen.table.DataGenTableSource.createSource()>
calls constructor
<org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource.<init>(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator,
long, java.lang.Long)> in (DataGenTableSource.java:72)
Method
<org.apache.flink.connector.datagen.table.DataGenTableSource.createSource()>
has return type
<org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource>
in (DataGenTableSource.java:0)
Method
<org.apache.flink.connector.datagen.table.DataGenTableSource.createSource()> is
annotated with <org.apache.flink.annotation.VisibleForTesting> in
(DataGenTableSource.java:0)
@@ -301,6 +297,7 @@ Method
<org.apache.flink.connector.file.sink.committer.FileCommitter.commit(java
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.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:233)
+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:233)
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:240)
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:150)
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:142)
@@ -482,6 +479,7 @@ Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializ
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
calls method <org.apache.flink.core.memory.DataInputDeserializer.readLong()>
in (FileSourceSplitSerializer.java:107)
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
calls method <org.apache.flink.core.memory.DataInputDeserializer.readLong()>
in (FileSourceSplitSerializer.java:108)
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
calls method <org.apache.flink.core.memory.DataInputDeserializer.readLong()>
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:112)
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.deserializeV1([B)>
calls method <org.apache.flink.core.memory.DataInputDeserializer.readUTF()> in
(FileSourceSplitSerializer.java:102)
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
calls method <org.apache.flink.core.memory.DataOutputSerializer.clear()> in
(FileSourceSplitSerializer.java:82)
Method
<org.apache.flink.connector.file.src.FileSourceSplitSerializer.serialize(org.apache.flink.connector.file.src.FileSourceSplit)>
calls method
<org.apache.flink.core.memory.DataOutputSerializer.getCopyOfBuffer()> in
(FileSourceSplitSerializer.java:81)
@@ -518,7 +516,7 @@ Method
<org.apache.flink.connector.file.table.FileInfoExtractorBulkFormat.wrapRe
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.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:0)
-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$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:555)
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)
Method
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamingSink(org.apache.flink.table.connector.ProviderContext,
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:233)
@@ -530,10 +528,10 @@ Method
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamin
Method
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamingSink(org.apache.flink.table.connector.ProviderContext,
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.legacy.StreamingFileSink$DefaultRowFormatBuilder.withRollingPolicy(org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy)>
in (FileSyst [...]
Method
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamingSink(org.apache.flink.table.connector.ProviderContext,
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.legacy.StreamingFileSink.forBulkFormat(org.apache.flink.core.fs.Path,
org.apache.flink.api.common.serialization.BulkWriter$Factory)> in
(FileSystemTable [...]
Method
<org.apache.flink.connector.file.table.FileSystemTableSink.createStreamingSink(org.apache.flink.table.connector.ProviderContext,
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.legacy.StreamingFileSink.forRowFormat(org.apache.flink.core.fs.Path,
org.apache.flink.api.common.serialization.Encoder)> in
(FileSystemTableSink.java:244)
-Method
<org.apache.flink.connector.file.table.FileSystemTableSource.getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource$ScanContext)>
calls constructor
<org.apache.flink.streaming.api.legacy.io.CollectionInputFormat.<init>(java.util.Collection,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(FileSystemTableSource.java:131)
-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.getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource$ScanContext)>
calls constructor
<org.apache.flink.streaming.api.legacy.io.CollectionInputFormat.<init>(java.util.Collection,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(FileSystemTableSource.java:130)
+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:327)
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.paths()>
references method
<org.apache.flink.table.utils.PartitionPathUtils.generatePartitionPath(java.util.LinkedHashMap)>
in (FileSystemTableSource.java:294)
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)
@@ -636,6 +634,7 @@ Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.coordinate(long,
java.util.Map)> calls constructor
<org.apache.flink.streaming.runtime.streamrecord.StreamRecord.<init>(java.lang.Object)>
in (CompactCoordinator.java:200)
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
calls constructor
<org.apache.flink.api.common.typeutils.base.ListSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer)>
in (CompactCoordinator.java:118)
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
calls constructor
<org.apache.flink.api.common.typeutils.base.MapSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(CompactCoordinator.java:118)
+Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
calls constructor
<org.apache.flink.api.common.typeutils.base.MapSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(CompactCoordinator.java:118)
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
calls constructor
<org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.<init>(java.lang.Class,
org.apache.flink.api.common.serialization.SerializerConfig)> in
(CompactCoordinator.java:118)
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
gets field
<org.apache.flink.api.common.typeutils.base.LongSerializer.INSTANCE> in
(CompactCoordinator.java:107)
Method
<org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.initializeState(org.apache.flink.runtime.state.StateInitializationContext)>
gets field
<org.apache.flink.api.common.typeutils.base.StringSerializer.INSTANCE> in
(CompactCoordinator.java:107)
@@ -678,6 +677,7 @@ Static Initializer
<org.apache.flink.connector.file.table.stream.AbstractStreami
Static Initializer
<org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger.<clinit>()>
calls constructor
<org.apache.flink.api.common.typeutils.base.ListSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer)>
in (PartitionTimeCommitTrigger.java:52)
Static Initializer
<org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger.<clinit>()>
calls constructor
<org.apache.flink.api.common.typeutils.base.MapSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(PartitionTimeCommitTrigger.java:56)
Static Initializer
<org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger.<clinit>()>
gets field
<org.apache.flink.api.common.typeutils.base.LongSerializer.INSTANCE> in
(PartitionTimeCommitTrigger.java:56)
+Static Initializer
<org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger.<clinit>()>
gets field
<org.apache.flink.api.common.typeutils.base.LongSerializer.INSTANCE> in
(PartitionTimeCommitTrigger.java:56)
Static Initializer
<org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger.<clinit>()>
gets field
<org.apache.flink.api.common.typeutils.base.StringSerializer.INSTANCE> in
(PartitionTimeCommitTrigger.java:52)
Static Initializer
<org.apache.flink.connector.file.table.stream.ProcTimeCommitTrigger.<clinit>()>
calls constructor
<org.apache.flink.api.common.typeutils.base.MapSerializer.<init>(org.apache.flink.api.common.typeutils.TypeSerializer,
org.apache.flink.api.common.typeutils.TypeSerializer)> in
(ProcTimeCommitTrigger.java:47)
Static Initializer
<org.apache.flink.connector.file.table.stream.ProcTimeCommitTrigger.<clinit>()>
gets field <org.apache.flink.api.common.typeutils.base.LongSerializer.INSTANCE>
in (ProcTimeCommitTrigger.java:47)
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 1ebd9c3a945..cf4dbf7fb01 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
@@ -23,7 +23,6 @@ import org.apache.flink.annotation.PublicEvolving;
import com.tngtech.archunit.base.DescribedPredicate;
import com.tngtech.archunit.core.domain.JavaClass;
-import com.tngtech.archunit.junit.ArchTag;
import com.tngtech.archunit.junit.ArchTest;
import com.tngtech.archunit.lang.ArchRule;
import com.tngtech.archunit.thirdparty.com.google.common.base.Joiner;
@@ -60,8 +59,6 @@ public class ConnectorRules {
}
@ArchTest
- @ArchTag(value = "org.apache.flink.testutils.junit.FailsOnJava11")
- @ArchTag(value = "org.apache.flink.testutils.junit.FailsOnJava17")
public static final ArchRule CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API =
freeze(
javaClassesThat(resideInAnyPackage(CONNECTOR_PACKAGES))
diff --git a/flink-end-to-end-tests/pom.xml b/flink-end-to-end-tests/pom.xml
index feec2ac33ef..9ff8809eda6 100644
--- a/flink-end-to-end-tests/pom.xml
+++ b/flink-end-to-end-tests/pom.xml
@@ -128,9 +128,6 @@ under the License.
<activation>
<jdk>[11,)</jdk>
</activation>
- <properties>
-
<excludeE2E>org.apache.flink.testutils.junit.FailsOnJava11</excludeE2E>
- </properties>
</profile>
<profile>
<id>java17</id>
diff --git
a/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
b/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
deleted file mode 100644
index f62abb00eac..00000000000
---
a/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
+++ /dev/null
@@ -1,21 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.testutils.junit;
-
-/** Marker interface for tests that fail on Java 11. */
-public interface FailsOnJava11 {}
diff --git a/pom.xml b/pom.xml
index 4586567bf7f..1939995d79f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1055,28 +1055,6 @@ under the License.
<activation>
<jdk>[11,)</jdk>
</activation>
-
- <properties>
-
<surefire.excludedGroups.jdk>org.apache.flink.testutils.junit.FailsOnJava11</surefire.excludedGroups.jdk>
- </properties>
-
- <build>
- <pluginManagement>
- <plugins>
- <plugin>
-
<groupId>org.apache.maven.plugins</groupId>
-
<artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <excludedGroups>
-
${surefire.excludedGroups.github-actions},
-
${surefire.excludedGroups.adaptive-scheduler},
-
${surefire.excludedGroups.jdk},
-
</excludedGroups>
- </configuration>
- </plugin>
- </plugins>
- </pluginManagement>
- </build>
</profile>
<profile>
