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中的addSource(org.apache.flink.streaming.api.functions.source.SourceFunction)已过时
[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
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中的addSource(org.apache.flink.streaming.api.functions.source.SourceFunction)已过时
[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