wenxuanzhen666 opened a new issue, #132:
URL: https://github.com/apache/rocketmq-flink/issues/132
C:\Program Files\JetBrains\IntelliJ IDEA
2025.1\plugins\maven\lib\maven3\bin\mvn.cmd -Didea.version=2026.1.3
-Dmaven.ext.class.path=C:\Program Files\JetBrains\IntelliJ IDEA
2025.1\plugins\maven\lib\intellij.maven.rt\maven-event-listener.jar
-Djansi.passthrough=true -Dstyle.color=always -DskipTests=true
-Dmaven.repo.local=C:\Users\MSI1\.m2\repository2 package -f pom.xml
[INFO] Scanning for projects...
[INFO]
[INFO] -------------< org.apache.flink:flink-connector-rocketmq
>--------------
[INFO] Building Flink : Connectors : RocketMQ 1.20.3
[INFO] from pom.xml
[INFO] --------------------------------[ jar
]---------------------------------
[INFO]
[INFO] --- spotless:2.13.0:check (spotless-check) @ flink-connector-rocketmq
---
[INFO]
[INFO] --- jacoco:0.8.7:prepare-agent (prepare-agent) @
flink-connector-rocketmq ---
[INFO] argLine set to
-javaagent:C:\\Users\\MSI1\\.m2\\repository2\\org\\jacoco\\org.jacoco.agent\\0.8.7\\org.jacoco.agent-0.8.7-runtime.jar=destfile=D:\\GitWorkSpace\\rocketmq-flink-main\\target\\jacoco.exec
[INFO]
[INFO] --- resources:3.3.1:resources (default-resources) @
flink-connector-rocketmq ---
[INFO] Copying 1 resource from src\main\resources to target\classes
[INFO]
[INFO] --- compiler:3.10.0:compile (default-compile) @
flink-connector-rocketmq ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] --- source:3.0.1:jar-no-fork (attach-sources) @
flink-connector-rocketmq ---
[INFO] Building jar:
D:\GitWorkSpace\rocketmq-flink-main\target\flink-connector-rocketmq-1.20.3-sources.jar
[INFO]
[INFO] --- resources:3.3.1:testResources (default-testResources) @
flink-connector-rocketmq ---
[INFO] Copying 1 resource from src\test\resources to target\test-classes
[INFO]
[INFO] --- compiler:3.10.0:testCompile (default-testCompile) @
flink-connector-rocketmq ---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 29 source files to
D:\GitWorkSpace\rocketmq-flink-main\target\test-classes
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[28,45]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[29,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[30,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[22,34]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[14,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[15,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[30,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[31,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[34,63]
org.apache.flink.streaming.api.functions.source.datagen中的org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[28,45]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[29,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[30,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[22,34]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[14,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[15,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[30,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[31,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[34,63]
org.apache.flink.streaming.api.functions.source.datagen中的org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[28,45]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[29,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[30,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[22,34]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[14,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[15,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[30,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[31,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[34,63]
org.apache.flink.streaming.api.functions.source.datagen中的org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[28,45]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[29,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[30,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[22,34]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[14,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[15,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[30,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[31,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[34,63]
org.apache.flink.streaming.api.functions.source.datagen中的org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:[24,55]
org.apache.flink.streaming.api.functions.source中的org.apache.flink.streaming.api.functions.source.SourceFunction已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[28,45]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[29,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[30,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[22,34]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[14,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java:[15,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[30,49]
org.apache.flink.runtime.state.filesystem中的org.apache.flink.runtime.state.filesystem.FsStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[31,38]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java:[34,63]
org.apache.flink.streaming.api.functions.source.datagen中的org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[92,33]
org.apache.flink.runtime.state.memory中的org.apache.flink.runtime.state.memory.MemoryStateBackend已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[92,12]
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment中的setStateBackend(org.apache.flink.runtime.state.StateBackend)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[93,41]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.TimeCharacteristic已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[93,12]
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment中的setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[99,56]
org.apache.flink.streaming.api中的org.apache.flink.streaming.api.CheckpointingMode已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[99,34]
org.apache.flink.streaming.api.environment.CheckpointConfig中的setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[109,41]
org.apache.flink.streaming.api.environment.CheckpointConfig中的org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[108,17]
org.apache.flink.streaming.api.environment.CheckpointConfig中的enableExternalizedCheckpoints(org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java:[117,20]
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment中的<OUT>addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[37,9]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java:[38,21]
org.apache.flink.table.api中的org.apache.flink.table.api.TableSchema已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactoryTest.java:[102,37]
org.apache.flink.table.catalog.CatalogTable中的of(org.apache.flink.table.api.Schema,java.lang.String,java.util.List<java.lang.String>,java.util.Map<java.lang.String,java.lang.String>)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactoryTest.java:[98,27]
org.apache.flink.table.factories.FactoryUtil中的createTableSink(org.apache.flink.table.catalog.Catalog,org.apache.flink.table.catalog.ObjectIdentifier,org.apache.flink.table.catalog.ResolvedCatalogTable,org.apache.flink.configuration.ReadableConfig,java.lang.ClassLoader,boolean)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:[119,37]
org.apache.flink.table.catalog.CatalogTable中的of(org.apache.flink.table.api.Schema,java.lang.String,java.util.List<java.lang.String>,java.util.Map<java.lang.String,java.lang.String>)已过时
[WARNING]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:[115,27]
org.apache.flink.table.factories.FactoryUtil中的createTableSource(org.apache.flink.table.catalog.Catalog,org.apache.flink.table.catalog.ObjectIdentifier,org.apache.flink.table.catalog.ResolvedCatalogTable,org.apache.flink.configuration.ReadableConfig,java.lang.ClassLoader,boolean)已过时
[INFO]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:
某些输入文件使用了未经检查或不安全的操作。
[INFO]
/D:/GitWorkSpace/rocketmq-flink-main/src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:
有关详细信息, 请使用 -Xlint:unchecked 重新编译。
[INFO]
[INFO] --- surefire:2.12.4:test (default-test) @ flink-connector-rocketmq ---
[INFO] Surefire report directory:
D:\GitWorkSpace\rocketmq-flink-main\target\surefire-reports
-------------------------------------------------------
T E S T S
-------------------------------------------------------
Running
org.apache.flink.connector.rocketmq.catalog.RocketMQCatalogFactoryTest
2026-07-03 16:13:50 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq-catalog
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.661 sec
Running org.apache.flink.connector.rocketmq.catalog.RocketMQCatalogTest
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
2026-07-03 16:13:51 INFO [ main]
[rocketmq.catalog.RocketMQCatalog] Created RocketMQ Catalog rocketmq_catalog
Tests run: 38, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.108 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.selector.DefaultTopicSelectorTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.selector.HashMessageQueueSelectorTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.selector.RandomMessageQueueSelectorTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.selector.SimpleTopicSelectorTest
2026-07-03 16:13:51 WARN [ main]
[.f.c.r.l.c.s.SimpleTopicSelector] Field tpc Not Found. Returning default topic
dtpc
2026-07-03 16:13:51 WARN [ main]
[.f.c.r.l.c.s.SimpleTopicSelector] Field tg Not Found. Returning default tag dtg
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.serialization.RowKeyValueDeserializationSchemaTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.177 sec
Running
org.apache.flink.connector.rocketmq.legacy.common.serialization.SimpleKeyValueSerializationSchemaTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running org.apache.flink.connector.rocketmq.legacy.common.util.RetryUtilTest
2026-07-03 16:14:02 INFO [ main]
[.c.r.l.common.util.RetryUtilTest] Thread has finished
Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 10.028 sec
<<< FAILURE!
testCall(org.apache.flink.connector.rocketmq.legacy.common.util.RetryUtilTest)
Time elapsed: 10.019 sec <<< FAILURE!
junit.framework.AssertionFailedError: expected:<0> but was:<12>
at junit.framework.Assert.fail(Assert.java:57)
at junit.framework.Assert.failNotEquals(Assert.java:329)
at junit.framework.Assert.assertEquals(Assert.java:78)
at junit.framework.Assert.assertEquals(Assert.java:234)
at junit.framework.Assert.assertEquals(Assert.java:241)
at junit.framework.TestCase.assertEquals(TestCase.java:384)
at
org.apache.flink.connector.rocketmq.legacy.common.util.RetryUtilTest.testCall(RetryUtilTest.java:53)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at junit.framework.TestCase.runTest(TestCase.java:177)
at junit.framework.TestCase.runBare(TestCase.java:142)
at junit.framework.TestResult$1.protect(TestResult.java:122)
at junit.framework.TestResult.runProtected(TestResult.java:142)
at junit.framework.TestResult.run(TestResult.java:125)
at junit.framework.TestCase.run(TestCase.java:130)
at junit.framework.TestSuite.runTest(TestSuite.java:241)
at junit.framework.TestSuite.run(TestSuite.java:236)
at
org.junit.internal.runners.JUnit38ClassRunner.run(JUnit38ClassRunner.java:90)
at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)
at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)
at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)
at
org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)
at
org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)
at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)
Running org.apache.flink.connector.rocketmq.legacy.RocketMQSinkTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 sec
Running org.apache.flink.connector.rocketmq.legacy.RocketMQSourceTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.legacy.sourceFunction.RocketMQSourceFunctionTest
2026-07-03 16:14:02 INFO [ main]
[.r.legacy.RocketMQSourceFunction] no restoredOffsets for [MessageQueue
[topic=tpc, brokerName=broker-2, queueId=0]], so init offset for these queues
2026-07-03 16:14:02 INFO [ main]
[.r.legacy.RocketMQSourceFunction] current consumer queue:broker-2-0 start from
offset of: 40
2026-07-03 16:14:02 INFO [ main]
[.r.legacy.RocketMQSourceFunction] init offset table [{MessageQueue [topic=tpc,
brokerName=broker-1, queueId=0]=30, MessageQueue [topic=tpc,
brokerName=broker-0, queueId=0]=20, MessageQueue [topic=tpc,
brokerName=broker-1, queueId=1]=31, MessageQueue [topic=tpc,
brokerName=broker-0, queueId=1]=21, MessageQueue [topic=tpc,
brokerName=broker-2, queueId=0]=40}] from restoredOffsets successful.
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.307 sec
Running
org.apache.flink.connector.rocketmq.sink.table.RocketMQDynamicTableSinkFactoryTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.063 sec
Running
org.apache.flink.connector.rocketmq.source.enumerator.allocate.AverageAllocateStrategyTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.005 sec
Running
org.apache.flink.connector.rocketmq.source.enumerator.allocate.BroadcastAllocateStrategyTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec
Running
org.apache.flink.connector.rocketmq.source.enumerator.allocate.ConsistentHashAllocateStrategyTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.source.enumerator.RocketMQSourceEnumStateSerializerTest
2026-07-03 16:14:02 INFO [ main]
[ocketMQSourceEnumStateSerializer] Serializer enumerator state,
{"currentSplitAssignment":[]}
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.126 sec
Running
org.apache.flink.connector.rocketmq.source.reader.deserializer.RocketMQRowDeserializationSchemaTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec
Running
org.apache.flink.connector.rocketmq.source.reader.RocketMQRecordEmitterTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec
Running
org.apache.flink.connector.rocketmq.source.split.RocketMQPartitionSplitSerializerTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002 sec
Running
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest
Tests run: 4, Failures: 0, Errors: 2, Skipped: 1, Time elapsed: 0.012 sec
<<< FAILURE!
testRocketMQDynamicTableSourceWithSql(org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest)
Time elapsed: 0.005 sec <<< ERROR!
org.apache.flink.table.api.ValidationException: Unable to create a source
for reading table 'default.default.rocketmq'.
Table options are:
'connector'='rocketmq'
'rocketmq.client.endpoints'='127.0.0.1:9876'
'rocketmq.source.filter.sql'='(TAGS is not null and TAGS in (''TagA'',
''TagB''))'
'rocketmq.source.group'='test_consumer'
'rocketmq.source.startup.offset.timestamp'='1783066442682'
'rocketmq.source.topic'='test_source'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:235)
at
org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:295)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.createTableSource(RocketMQDynamicTableSourceFactoryTest.java:115)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.createTableSource(RocketMQDynamicTableSourceFactoryTest.java:131)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.testRocketMQDynamicTableSourceWithSql(RocketMQDynamicTableSourceFactoryTest.java:108)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)
at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)
at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)
at
org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)
at
org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)
at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported
options found for 'rocketmq'.
Unsupported options:
rocketmq.client.endpoints
Supported options:
connector
property-version
rocketmq.client.accessKey
rocketmq.client.message.encoding
rocketmq.client.message.field.delimiter
rocketmq.client.message.length.check
rocketmq.client.message.line.delimiter
rocketmq.client.secretKey
rocketmq.client.timeZone
rocketmq.source.column.error.debug
rocketmq.source.filter.sql
rocketmq.source.filter.tag
rocketmq.source.group
rocketmq.source.pull.rpc.timeout
rocketmq.source.startup.offset.specific
rocketmq.source.startup.offset.timestamp
rocketmq.source.startup.scan.mode
rocketmq.source.stop.offset.timestamp
rocketmq.source.topic
scan.watermark.alignment.group
scan.watermark.alignment.max-drift
scan.watermark.alignment.update-interval
scan.watermark.emit.strategy
scan.watermark.idle-timeout
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:710)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:1009)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactory.createDynamicTableSource(RocketMQDynamicTableSourceFactory.java:89)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:232)
... 36 more
testRocketMQDynamicTableSourceWithLegalOption(org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest)
Time elapsed: 0.004 sec <<< ERROR!
org.apache.flink.table.api.ValidationException: Unable to create a source
for reading table 'default.default.rocketmq'.
Table options are:
'connector'='rocketmq'
'rocketmq.client.endpoints'='127.0.0.1:9876'
'rocketmq.source.group'='test_consumer'
'rocketmq.source.startup.offset.timestamp'='1783066442691'
'rocketmq.source.topic'='test_source'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:235)
at
org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:295)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.createTableSource(RocketMQDynamicTableSourceFactoryTest.java:115)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.createTableSource(RocketMQDynamicTableSourceFactoryTest.java:131)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest.testRocketMQDynamicTableSourceWithLegalOption(RocketMQDynamicTableSourceFactoryTest.java:69)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)
at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)
at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)
at
org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)
at
org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)
at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported
options found for 'rocketmq'.
Unsupported options:
rocketmq.client.endpoints
Supported options:
connector
property-version
rocketmq.client.accessKey
rocketmq.client.message.encoding
rocketmq.client.message.field.delimiter
rocketmq.client.message.length.check
rocketmq.client.message.line.delimiter
rocketmq.client.secretKey
rocketmq.client.timeZone
rocketmq.source.column.error.debug
rocketmq.source.filter.sql
rocketmq.source.filter.tag
rocketmq.source.group
rocketmq.source.pull.rpc.timeout
rocketmq.source.startup.offset.specific
rocketmq.source.startup.offset.timestamp
rocketmq.source.startup.scan.mode
rocketmq.source.stop.offset.timestamp
rocketmq.source.topic
scan.watermark.alignment.group
scan.watermark.alignment.max-drift
scan.watermark.alignment.update-interval
scan.watermark.emit.strategy
scan.watermark.idle-timeout
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:710)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:1009)
at
org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactory.createDynamicTableSource(RocketMQDynamicTableSourceFactory.java:89)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:232)
... 36 more
Results :
Failed tests:
testCall(org.apache.flink.connector.rocketmq.legacy.common.util.RetryUtilTest):
expected:<0> but was:<12>
Tests in error:
testRocketMQDynamicTableSourceWithSql(org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest):
Unable to create a source for reading table 'default.default.rocketmq'.(..)
testRocketMQDynamicTableSourceWithLegalOption(org.apache.flink.connector.rocketmq.source.table.RocketMQDynamicTableSourceFactoryTest):
Unable to create a source for reading table 'default.default.rocketmq'.(..)
Tests run: 71, Failures: 1, Errors: 2, Skipped: 4
[INFO]
------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO]
------------------------------------------------------------------------
[INFO] Total time: 32.489 s
[INFO] Finished at: 2026-07-03T16:14:02+08:00
[INFO]
------------------------------------------------------------------------
[ERROR] Failed to execute goal
org.apache.maven.plugins:maven-surefire-plugin:2.12.4:test (default-test) on
project flink-connector-rocketmq: There are test failures.
[ERROR]
[ERROR] Please refer to
D:\GitWorkSpace\rocketmq-flink-main\target\surefire-reports for the individual
test results.
[ERROR] -> [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/MojoFailureException
--
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]
