package error

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.util.Map)已过时
[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.util.Map)已过时
[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

Start with the full output from the Maven package command in pom.xml; the report currently shows compilation warnings but cuts off before the package failure. Reproduce the command without skipping the relevant output, identify the first actual error, and confirm that packaging completes successfully.

Written by the indexing model from the issue text.