JingsongLi opened a new pull request, #9451:
URL: https://github.com/apache/paimon/pull/9451
## Purpose\n\nAllow unaligned checkpoints for append-table streaming writes
using coordinator commit, while keeping the classic committer and other sink
paths rejected.\n\n## Changes\n\n- Scope unaligned checkpoint support to
coordinator commit.\n- Keep the EXACTLY_ONCE checkpoint mode requirement.\n-
Add boundary tests for coordinator and classic commit paths.\n- Add an
integration test using an append table with data evolution and row tracking
enabled.\n\n## Tests\n\n- Flink 1 / Java 8: [INFO] Scanning for projects...
[WARNING]
[WARNING] Some problems were encountered while building the effective model
for org.apache.paimon:paimon-spark-common_2.12:jar:2.1-SNAPSHOT
[WARNING] 'artifactId' contains an expression but should be a constant. @
org.apache.paimon:paimon-spark-common_${scala.binary.version}:2.1-SNAPSHOT,
/Users/lijingsong/IdeaProjects/paimon2/paimon-spark/paimon-spark-common/pom.xml,
line 33, column 17
[WARNING]
[WARNING] Some problems were encountered while building the effective model
for org.apache.paimon:paimon-spark-ut_2.12:jar:2.1-SNAPSHOT
[WARNING] 'artifactId' contains an expression but should be a constant. @
org.apache.paimon:paimon-spark-ut_${scala.binary.version}:2.1-SNAPSHOT,
/Users/lijingsong/IdeaProjects/paimon2/paimon-spark/paimon-spark-ut/pom.xml,
line 31, column 17
[WARNING]
[WARNING] It is highly recommended to fix these problems because they
threaten the stability of your build.
[WARNING]
[WARNING] For this reason, future Maven versions might no longer support
building such malformed projects.
[WARNING]
[INFO]
------------------------------------------------------------------------
[INFO] Detecting the operating system and CPU architecture
[INFO]
------------------------------------------------------------------------
[INFO] os.detected.name: osx
[INFO] os.detected.arch: aarch_64
[INFO] os.detected.bitness: 64
[INFO] os.detected.version: 26.3
[INFO] os.detected.version.major: 26
[INFO] os.detected.version.minor: 3
[INFO] os.detected.classifier: osx-aarch_64
[INFO]
[INFO] ---------------< org.apache.paimon:paimon-flink-common
>----------------
[INFO] Building Paimon : Flink : Common 2.1-SNAPSHOT
[INFO] from pom.xml
[INFO] --------------------------------[ jar
]---------------------------------
[INFO]
[INFO] --- clean:3.1.0:clean (default-clean) @ paimon-flink-common ---
[INFO] Deleting
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/target
[INFO] Deleting
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common
(includes = [dependency-reduced-pom.xml], excludes = [])
[INFO]
[INFO] --- checkstyle:2.17:check (validate) @ paimon-flink-common ---
[INFO]
[INFO] --- spotless:2.13.0:check (spotless-check) @ paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (enforce-maven-version) @
paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (enforce-maven) @ paimon-flink-common
---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (ban-unsafe-snakeyaml) @
paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (ban-unsafe-jackson) @
paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (forbid-log4j-1) @ paimon-flink-common
---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce
(forbid-direct-table-planner-dependencies) @ paimon-flink-common ---
[INFO]
[INFO] --- directory:1.0:directory-of (directories) @ paimon-flink-common ---
[INFO] Directory of org.apache.paimon:paimon-parent set to:
/Users/lijingsong/IdeaProjects/paimon2
[INFO]
[INFO] --- remote-resources:1.7.0:process (process-resource-bundles) @
paimon-flink-common ---
[INFO] Preparing remote bundle org.apache:apache-jar-resource-bundle:1.4
[INFO] Copying 3 resources from 1 bundle.
[INFO]
[INFO] --- resources:3.1.0:resources (default-resources) @
paimon-flink-common ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 3 resources
[INFO] Copying 3 resources
[INFO]
[INFO] --- compiler:3.8.0:compile (default-compile) @ paimon-flink-common ---
[INFO] Compiling 535 source files to
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/target/classes
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java:[40,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java:[48,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ReassignRowIdAction.java:[32,55]
org.apache.flink.streaming.api.functions.source.SourceFunction in
org.apache.flink.streaming.api.functions.source has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CopyFilesProcedure.java:[21,38]
org.apache.paimon.flink.action.CopyFilesAction in
org.apache.paimon.flink.action has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java:[120,18]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java:[324,42]
getCheckpointingMode() in
org.apache.flink.streaming.api.environment.CheckpointConfig has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java:[324,69]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java:[150,41]
CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL in
org.apache.paimon.flink.FlinkConnectorOptions has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java:[152,37]
CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL in
org.apache.paimon.flink.FlinkConnectorOptions has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java:[111,20]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java:[150,20]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java:[248,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkFormatTableDataStreamSink.java:[89,36]
createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext) in
org.apache.flink.api.connector.sink2.Sink has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkFormatTableDataStreamSink.java:[89,49]
org.apache.flink.api.connector.sink2.Sink.InitContext in
org.apache.flink.api.connector.sink2.Sink has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java:[349,32]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java:[243,23]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java:[522,42]
getCheckpointingMode() in
org.apache.flink.streaming.api.environment.CheckpointConfig has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java:[522,69]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/DataEvolutionCompactionTaskTypeInfo.java:[72,53]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCommittableTypeInfo.java:[71,50]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/service/QueryAddressRegister.java:[47,36]
createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext) in
org.apache.flink.api.connector.sink2.Sink has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/service/QueryAddressRegister.java:[47,49]
org.apache.flink.api.connector.sink2.Sink.InitContext in
org.apache.flink.api.connector.sink2.Sink has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneHiveTableUtils.java:[134,19]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogTaskTypeInfo.java:[71,49]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ClonePaimonTableUtils.java:[125,19]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ReassignRowIdAction.java:[78,20]
<OUT>addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>,java.lang.String,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ReassignRowIdAction.java:[146,57]
org.apache.flink.streaming.api.functions.source.SourceFunction in
org.apache.flink.streaming.api.functions.source has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java:[87,30]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/StatisticsOrRecordTypeInfo.java:[83,47]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommittableTypeInfo.java:[71,40]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactionTaskTypeInfo.java:[72,46]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCompactionTaskTypeInfo.java:[74,56]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/JavaTypeInfo.java:[92,30]
createSerializer(org.apache.flink.api.common.ExecutionConfig) in
org.apache.flink.api.common.typeinfo.TypeInformation has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopySourceBuilder.java:[123,19]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[INFO]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java:
Some input files use unchecked or unsafe operations.
[INFO]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java:
Recompile with -Xlint:unchecked for details.
[INFO]
[INFO] --- resources:3.1.0:testResources (default-testResources) @
paimon-flink-common ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 6 resources
[INFO] Copying 3 resources
[INFO]
[INFO] --- compiler:3.8.0:testCompile (default-testCompile) @
paimon-flink-common ---
[INFO] Compiling 302 source files to
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/target/test-classes
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:[32,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[34,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:[32,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[34,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:[32,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[34,38]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:[301,68]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:[301,46]
setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode) in
org.apache.flink.streaming.api.environment.CheckpointConfig has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogITCaseBase.java:[98,13]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogITCaseBase.java:[131,25]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkBuilderLineageTest.java:[58,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkChainTableITCaseBase.java:[109,37]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkChainTableITCaseBase.java:[138,37]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/ReadWriteTableTestUtil.java:[96,13]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkChainTableITCase.java:[3349,23]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CreateTableITCase.java:[101,21]
getCause() in org.assertj.core.api.AbstractThrowableAssert has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkFormatTableDataStreamSinkTest.java:[69,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputPartitionExpireITCase.java:[110,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileStoreITCase.java:[241,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileStoreITCase.java:[260,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileStoreITCase.java:[276,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileStoreITCase.java:[529,22]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SortedGlobalIndexITCase.java:[599,63]
<OUT>fromElements(OUT...) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SortedGlobalIndexITCase.java:[626,53]
<OUT>fromElements(OUT...) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendTableITCase.java:[489,13]
registerCatalog(java.lang.String,org.apache.flink.table.catalog.Catalog) in
org.apache.flink.table.api.TableEnvironment has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CopyFilesActionITCase.java:[908,17]
org.apache.paimon.flink.action.CopyFilesAction in
org.apache.paimon.flink.action has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CopyFilesActionITCase.java:[908,43]
org.apache.paimon.flink.action.CopyFilesAction in
org.apache.paimon.flink.action has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CopyFilesActionITCase.java:[963,9]
org.apache.paimon.flink.action.CopyFilesAction in
org.apache.paimon.flink.action has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CopyFilesActionITCase.java:[963,35]
org.apache.paimon.flink.action.CopyFilesAction in
org.apache.paimon.flink.action has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkBatchJobPartitionMarkdoneITCase.java:[137,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java:[127,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[144,57]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[152,61]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[166,61]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[203,35]
org.apache.flink.streaming.api.CheckpointingMode in
org.apache.flink.streaming.api has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[207,34]
setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode) in
org.apache.flink.streaming.api.environment.CheckpointConfig has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/FlinkSinkTest.java:[210,20]
<OUT>fromCollection(java.util.Collection<OUT>,org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
in org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has
been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java:[306,38]
CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL in
org.apache.paimon.flink.FlinkConnectorOptions has been deprecated
[WARNING]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ReadWriteTableITCase.java:[1941,24]
<OUT>fromCollection(java.util.Collection<OUT>) in
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment has been
deprecated
[INFO]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:
Some input files use unchecked or unsafe operations.
[INFO]
/Users/lijingsong/IdeaProjects/paimon2/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/util/AbstractTestBase.java:
Recompile with -Xlint:unchecked for details.
[INFO]
[INFO] --- surefire:3.0.0-M5:test (default-test) @ paimon-flink-common ---
[INFO]
[INFO] -------------------------------------------------------
[INFO] T E S T S
[INFO] -------------------------------------------------------
[INFO] Running org.apache.paimon.flink.sink.FlinkSinkTest
[INFO] Running org.apache.paimon.flink.CoordinatorCommitITCase
[INFO] Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed:
0.378 s - in org.apache.paimon.flink.sink.FlinkSinkTest
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.901
s - in org.apache.paimon.flink.CoordinatorCommitITCase
[INFO]
[INFO] Results:
[INFO]
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0
[INFO]
[INFO]
------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO]
------------------------------------------------------------------------
[INFO] Total time: 28.223 s
[INFO] Finished at: 2026-08-28T20:44:38+08:00
[INFO]
------------------------------------------------------------------------\n-
Flink 2 / Java 11: [INFO] Scanning for projects...
[WARNING]
[WARNING] Some problems were encountered while building the effective model
for org.apache.paimon:paimon-spark-common_2.12:jar:2.1-SNAPSHOT
[WARNING] 'artifactId' contains an expression but should be a constant. @
org.apache.paimon:paimon-spark-common_${scala.binary.version}:2.1-SNAPSHOT,
/Users/lijingsong/IdeaProjects/paimon2/paimon-spark/paimon-spark-common/pom.xml,
line 33, column 17
[WARNING]
[WARNING] Some problems were encountered while building the effective model
for org.apache.paimon:paimon-spark-ut_2.12:jar:2.1-SNAPSHOT
[WARNING] 'artifactId' contains an expression but should be a constant. @
org.apache.paimon:paimon-spark-ut_${scala.binary.version}:2.1-SNAPSHOT,
/Users/lijingsong/IdeaProjects/paimon2/paimon-spark/paimon-spark-ut/pom.xml,
line 31, column 17
[WARNING]
[WARNING] It is highly recommended to fix these problems because they
threaten the stability of your build.
[WARNING]
[WARNING] For this reason, future Maven versions might no longer support
building such malformed projects.
[WARNING]
[INFO]
------------------------------------------------------------------------
[INFO] Detecting the operating system and CPU architecture
[INFO]
------------------------------------------------------------------------
[INFO] os.detected.name: osx
[INFO] os.detected.arch: aarch_64
[INFO] os.detected.bitness: 64
[INFO] os.detected.version: 26.3
[INFO] os.detected.version.major: 26
[INFO] os.detected.version.minor: 3
[INFO] os.detected.classifier: osx-aarch_64
[INFO]
[INFO] ---------------< org.apache.paimon:paimon-flink-common
>----------------
[INFO] Building Paimon : Flink : Common 2.1-SNAPSHOT
[INFO] from pom.xml
[INFO] --------------------------------[ jar
]---------------------------------
[INFO]
[INFO] --- checkstyle:2.17:check (validate) @ paimon-flink-common ---
[INFO]
[INFO] --- spotless:2.13.0:check (spotless-check) @ paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (enforce-maven-version) @
paimon-flink-common ---
[INFO]
[INFO] --- enforcer:3.0.0-M1:enforce (enforce-maven) @ paimon-flink-common
---
[WARNING] Rule 1: org.apache.maven.plugins.enforcer.RequireJavaVersion
failed with message:
Detected JDK Version: 1.8.0-432 is not in the allowed range 11.
[INFO]
------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO]
------------------------------------------------------------------------
[INFO] Total time: 8.772 s
[INFO] Finished at: 2026-08-28T20:44:48+08:00
[INFO]
------------------------------------------------------------------------
[ERROR] Failed to execute goal
org.apache.maven.plugins:maven-enforcer-plugin:3.0.0-M1:enforce (enforce-maven)
on project paimon-flink-common: Some Enforcer rules have failed. Look above for
specific messages explaining why the rule failed. -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e
switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please
read the following articles:
[ERROR] [Help 1]
http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
