andyuan1000 opened a new issue, #8408: URL: https://github.com/apache/seatunnel/issues/8408
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened 运行这个类：SeaTunnelApiExample 执行mysql同步到sr这是配置脚本 代码：已经编译一直报这个错，在windows环境运行也是报这个错 ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf #定义一些作业的运行参数,具体可以参考 https://seatunnel.apache.org/docs/2.3.1/concept/JobEnvConfig env { job.mode="BATCH" #作业的运行模式，BATCH=离线批同步，STREAMING=实时同步 job.name="SeaTunnel_market_new_58_163_sr_Job" checkpoint.interval=10000 #每10000ms进行一次checkpoint，后面会详细介绍checkpoint对JDBC Source和StarRocks Sink这两个连接器的影响 } source { Jdbc { parallelism=2 # 并行度，这里是启动5个Source Task来并行的读取数据 partition_column="id" # 使用id字段来进行split的拆分，目前只支持数字类型的主键列，而且该列的值最好是离线的，自增id最佳 partition_num="10" # 拆分成20个split，这20个split会被分配给5个Source Task来处理 result_table_name="t_electronic_back_order" query="SELECT `id`, `order_code`, `status`, `create_date`, `order_total_price`, `order_pay_mode`, `old_order_code`, `actual_money`, `operate_flag`, `order_commodity_weight`, `cabinet_name`, `cabinet_code`FROM `market_new2`.`t_electronic_back_order`" password="hdic2011" driver="com.mysql.cj.jdbc.Driver" user=root url="jdbc:mysql://xx:23306/market_new2?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useSSL=false" } } transform { # 在本次示例中我们不需要做任务的Transform操作，所以这里为空，也可以将transform整个元素删除 } sink { StarRocks { batch_max_rows=10240 # source_table_name="t_electronic_back_order" table="t_electronic_back_order_st" database="market_new_dw" base-url="jdbc:mysql://10.96.9.163:9030/market_new_dw" password="root" username="Hdic@2024" nodeUrls=[ "10.96.9.163:8040" #写入数据是通过StarRocks的Http接口 ] } } ``` ### Running Command ```shell 运行这个类：SeaTunnelApiExample ``` ### Error Exception ```log "C:\Program Files\Java\jdk-11\bin\java.exe" "-javaagent:D:\softinstall\JetBrains\IntelliJ IDEA 2024.1.4\lib\idea_rt.jar=54182:D:\softinstall\JetBrains\IntelliJ IDEA 2024.1.4\bin" -Dfile.encoding=UTF-8 -classpath D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-examples\seatunnel-flink-connector-v2-example\target\classes;D:\apache-maven-3.9.9\repository\com\starrocks\starrocks-thrift-sdk\1.0.1\starrocks-thrift-sdk-1.0.1.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-jdbc\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-common\target\classes;D:\apache-maven-3.9.9\repository\com\zaxxer\HikariCP\4.0.3\HikariCP-4.0.3.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-cdc\connector-cdc-mysql\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-cdc\connector-cdc-base\target\classes;D:\apache-maven-3.9.9\repository\io\debezium\debezium-api\1 .9.8.Final\debezium-api-1.9.8.Final.jar;D:\apache-maven-3.9.9\repository\io\debezium\debezium-embedded\1.9.8.Final\debezium-embedded-1.9.8.Final.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\connect-api\3.2.0\connect-api-3.2.0.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\kafka-clients\3.2.0\kafka-clients-3.2.0.jar;D:\apache-maven-3.9.9\repository\javax\ws\rs\javax.ws.rs-api\2.1.1\javax.ws.rs-api-2.1.1.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\connect-runtime\3.2.0\connect-runtime-3.2.0.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\connect-transforms\3.2.0\connect-transforms-3.2.0.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\kafka-tools\3.2.0\kafka-tools-3.2.0.jar;D:\apache-maven-3.9.9\repository\net\sourceforge\argparse4j\argparse4j\0.7.0\argparse4j-0.7.0.jar;D:\apache-maven-3.9.9\repository\ch\qos\reload4j\reload4j\1.2.19\reload4j-1.2.19.jar;D:\apache-maven-3.9.9\repository\org\bitbucket\b_c\jose4j\0.7.9\jose4j-0.7.9.jar;D:\apache-maven -3.9.9\repository\com\fasterxml\jackson\core\jackson-annotations\2.13.3\jackson-annotations-2.13.3.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\jaxrs\jackson-jaxrs-json-provider\2.12.6\jackson-jaxrs-json-provider-2.12.6.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\jaxrs\jackson-jaxrs-base\2.12.6\jackson-jaxrs-base-2.12.6.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\module\jackson-module-jaxb-annotations\2.12.6\jackson-module-jaxb-annotations-2.12.6.jar;D:\apache-maven-3.9.9\repository\jakarta\xml\bind\jakarta.xml.bind-api\2.3.2\jakarta.xml.bind-api-2.3.2.jar;D:\apache-maven-3.9.9\repository\jakarta\activation\jakarta.activation-api\1.2.1\jakarta.activation-api-1.2.1.jar;D:\apache-maven-3.9.9\repository\org\glassfish\jersey\containers\jersey-container-servlet\2.34\jersey-container-servlet-2.34.jar;D:\apache-maven-3.9.9\repository\org\glassfish\jersey\containers\jersey-container-servlet-core\2.34\jersey-container-servlet-core-2.34.jar;D:\apach e-maven-3.9.9\repository\org\glassfish\hk2\external\jakarta.inject\2.6.1\jakarta.inject-2.6.1.jar;D:\apache-maven-3.9.9\repository\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;D:\apache-maven-3.9.9\repository\org\glassfish\jersey\inject\jersey-hk2\2.34\jersey-hk2-2.34.jar;D:\apache-maven-3.9.9\repository\org\glassfish\hk2\hk2-locator\2.6.1\hk2-locator-2.6.1.jar;D:\apache-maven-3.9.9\repository\org\glassfish\hk2\external\aopalliance-repackaged\2.6.1\aopalliance-repackaged-2.6.1.jar;D:\apache-maven-3.9.9\repository\org\glassfish\hk2\hk2-api\2.6.1\hk2-api-2.6.1.jar;D:\apache-maven-3.9.9\repository\org\glassfish\hk2\hk2-utils\2.6.1\hk2-utils-2.6.1.jar;D:\apache-maven-3.9.9\repository\javax\xml\bind\jaxb-api\2.3.0\jaxb-api-2.3.0.jar;D:\apache-maven-3.9.9\repository\javax\activation\activation\1.1.1\activation-1.1.1.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-server\9.4.44.v20210927\jetty-server-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\ja vax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-http\9.4.44.v20210927\jetty-http-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-io\9.4.44.v20210927\jetty-io-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-servlet\9.4.44.v20210927\jetty-servlet-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-security\9.4.44.v20210927\jetty-security-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-util-ajax\9.4.44.v20210927\jetty-util-ajax-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-servlets\9.4.44.v20210927\jetty-servlets-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-continuation\9.4.44.v20210927\jetty-continuation-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-util\9.4.44.v20210927\jetty-util-9.4.44.v20210927.jar;D :\apache-maven-3.9.9\repository\org\eclipse\jetty\jetty-client\9.4.44.v20210927\jetty-client-9.4.44.v20210927.jar;D:\apache-maven-3.9.9\repository\org\reflections\reflections\0.9.12\reflections-0.9.12.jar;D:\apache-maven-3.9.9\repository\org\apache\maven\maven-artifact\3.8.4\maven-artifact-3.8.4.jar;D:\apache-maven-3.9.9\repository\org\codehaus\plexus\plexus-utils\3.3.0\plexus-utils-3.3.0.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\connect-json\3.2.0\connect-json-3.2.0.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.12.6\jackson-datatype-jdk8-2.12.6.jar;D:\apache-maven-3.9.9\repository\org\apache\kafka\connect-file\3.2.0\connect-file-3.2.0.jar;D:\apache-maven-3.9.9\repository\com\github\luben\zstd-jni\1.5.5-5\zstd-jni-1.5.5-5.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-formats\seatunnel-format-compatible-debezium-json\target\classes;D:\apache-maven-3.9.9\repository\io\debezium\debezium-connector-mysql\1.9.8.Final\deb ezium-connector-mysql-1.9.8.Final.jar;D:\apache-maven-3.9.9\repository\io\debezium\debezium-core\1.9.8.Final\debezium-core-1.9.8.Final.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\core\jackson-core\2.13.3\jackson-core-2.13.3.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\core\jackson-databind\2.13.3\jackson-databind-2.13.3.jar;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.13.3\jackson-datatype-jsr310-2.13.3.jar;D:\apache-maven-3.9.9\repository\io\debezium\debezium-ddl-parser\1.9.8.Final\debezium-ddl-parser-1.9.8.Final.jar;D:\apache-maven-3.9.9\repository\org\antlr\antlr4-runtime\4.8\antlr4-runtime-4.8.jar;D:\apache-maven-3.9.9\repository\com\zendesk\mysql-binlog-connector-java\0.27.2\mysql-binlog-connector-java-0.27.2.jar;D:\apache-maven-3.9.9\repository\mysql\mysql-connector-java\8.0.27\mysql-connector-java-8.0.27.jar;D:\apache-maven-3.9.9\repository\com\google\protobuf\protobuf-java\3.11.4\protobuf-java-3.11.4.j ar;D:\apache-maven-3.9.9\repository\com\typesafe\config\1.3.3\config-1.3.3.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-core\seatunnel-flink-starter\seatunnel-flink-15-starter\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-core\seatunnel-flink-starter\seatunnel-flink-starter-common\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-translation\seatunnel-translation-flink\seatunnel-translation-flink-15\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-translation\seatunnel-translation-flink\seatunnel-translation-flink-common\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-translation\seatunnel-translation-base\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-core\seatunnel-core-starter\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-api\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\target\classes;D:\apache-maven-3.9.9\repository\o rg\apache\commons\commons-collections4\4.4\commons-collections4-4.4.jar;D:\apache-maven-3.9.9\repository\org\apache\commons\commons-csv\1.10.0\commons-csv-1.10.0.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-guava\target\seatunnel-guava.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-guava\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-jackson\target\seatunnel-jackson.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-jackson\target\classes;D:\apache-maven-3.9.9\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-properties\2.13.3\jackson-dataformat-properties-2.13.3.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-config\seatunnel-config-sql\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-config\seatunnel-config-shade\target\seatunnel-config-shade-2.3.8.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-config\seatunnel-config-s hade\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-config\seatunnel-config-base\target\seatunnel-config-base-2.3.8.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-config\seatunnel-config-base\target\classes;D:\apache-maven-3.9.9\repository\org\scala-lang\scala-library\2.12.15\scala-library-2.12.15.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-plugin-discovery\target\classes;D:\apache-maven-3.9.9\repository\org\apache\commons\commons-compress\1.20\commons-compress-1.20.jar;D:\apache-maven-3.9.9\repository\com\beust\jcommander\1.81\jcommander-1.81.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-transforms-v2\target\classes;D:\apache-maven-3.9.9\repository\com\github\jsqlparser\jsqlparser\4.5\jsqlparser-4.5.jar;D:\apache-maven-3.9.9\repository\com\jayway\jsonpath\json-path\2.7.0\json-path-2.7.0.jar;D:\apache-maven-3.9.9\repository\net\minidev\json-smart\2.4.7\json-smart-2.4.7.jar;D:\apache-maven-3.9.9\repository\net\minidev\accessors-s mart\2.4.7\accessors-smart-2.4.7.jar;D:\apache-maven-3.9.9\repository\org\ow2\asm\asm\9.1\asm-9.1.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-formats\seatunnel-format-json\target\classes;D:\apache-maven-3.9.9\repository\org\apache\groovy\groovy\4.0.16\groovy-4.0.16.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-janino\target\seatunnel-janino.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-shade\seatunnel-janino\target\classes;D:\apache-maven-3.9.9\repository\org\apache\httpcomponents\httpclient\4.5.13\httpclient-4.5.13.jar;D:\apache-maven-3.9.9\repository\commons-codec\commons-codec\1.13\commons-codec-1.13.jar;D:\apache-maven-3.9.9\repository\org\apache\httpcomponents\httpcore\4.4.4\httpcore-4.4.4.jar;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-fake\target\classes;D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-connectors-v2\connector-console\target\classes;D:\apache-maven-3.9.9\repository\org\apac he\flink\flink-java\1.15.3\flink-java-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-core\1.15.3\flink-core-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-annotations\1.15.3\flink-annotations-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-metrics-core\1.15.3\flink-metrics-core-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-asm-9\9.2-15.0\flink-shaded-asm-9-9.2-15.0.jar;D:\apache-maven-3.9.9\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;D:\apache-maven-3.9.9\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;D:\apache-maven-3.9.9\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\apache-maven-3.9.9\repository\org\apache\commons\commons-lang3\3.5\commons-lang3-3.5.jar;D:\apache-maven-3.9.9\repository\org\apache\commons\commons-math3\3.6.1\commons-math3-3.6.1.jar;D:\apache-maven-3.9.9\repository\com\twitter\chill-java\0.7.6\chill -java-0.7.6.jar;D:\apache-maven-3.9.9\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-force-shading\15.0\flink-shaded-force-shading-15.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-streaming-java\1.15.3\flink-streaming-java-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-file-sink-common\1.15.3\flink-file-sink-common-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-runtime\1.15.3\flink-runtime-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-rpc-core\1.15.3\flink-rpc-core-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-rpc-akka-loader\1.15.3\flink-rpc-akka-loader-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-queryable-state-client-java\1.15.3\flink-queryable-state-client-java-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-hadoop-fs\1.15.3\flink-hadoop-fs-1.15.3.jar;D:\apache -maven-3.9.9\repository\commons-io\commons-io\2.11.0\commons-io-2.11.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-netty\4.1.70.Final-15.0\flink-shaded-netty-4.1.70.Final-15.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-jackson\2.12.4-15.0\flink-shaded-jackson-2.12.4-15.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-zookeeper-3\3.5.9-15.0\flink-shaded-zookeeper-3-3.5.9-15.0.jar;D:\apache-maven-3.9.9\repository\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;D:\apache-maven-3.9.9\repository\org\xerial\snappy\snappy-java\1.1.8.3\snappy-java-1.1.8.3.jar;D:\apache-maven-3.9.9\repository\org\lz4\lz4-java\1.8.0\lz4-java-1.8.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-shaded-guava\30.1.1-jre-15.0\flink-shaded-guava-30.1.1-jre-15.0.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-table-api-java\1.15.3\flink-table-api-java-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\fli nk-table-common\1.15.3\flink-table-common-1.15.3.jar;D:\apache-maven-3.9.9\repository\com\ibm\icu\icu4j\67.1\icu4j-67.1.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-table-api-java-bridge\1.15.3\flink-table-api-java-bridge-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-table-api-bridge-base\1.15.3\flink-table-api-bridge-base-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-table-planner-loader\1.15.3\flink-table-planner-loader-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-table-runtime\1.15.3\flink-table-runtime-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-cep\1.15.3\flink-cep-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-clients\1.15.3\flink-clients-1.15.3.jar;D:\apache-maven-3.9.9\repository\org\apache\flink\flink-optimizer\1.15.3\flink-optimizer-1.15.3.jar;D:\apache-maven-3.9.9\repository\commons-cli\commons-cli\1.5.0\commons-cli-1.5.0.jar;D:\apache-maven-3.9.9\repo sitory\com\squareup\okhttp3\mockwebserver\3.6.0\mockwebserver-3.6.0.jar;D:\apache-maven-3.9.9\repository\com\squareup\okhttp3\okhttp\3.6.0\okhttp-3.6.0.jar;D:\apache-maven-3.9.9\repository\com\squareup\okio\okio\1.11.0\okio-1.11.0.jar;D:\apache-maven-3.9.9\repository\org\bouncycastle\bcprov-jdk15on\1.50\bcprov-jdk15on-1.50.jar;D:\apache-maven-3.9.9\repository\junit\junit\4.13.2\junit-4.13.2.jar;D:\apache-maven-3.9.9\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;D:\apache-maven-3.9.9\repository\com\google\guava\guava\27.0-jre\guava-27.0-jre.jar;D:\apache-maven-3.9.9\repository\com\google\guava\failureaccess\1.0\failureaccess-1.0.jar;D:\apache-maven-3.9.9\repository\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;D:\apache-maven-3.9.9\repository\org\checkerframework\checker-qual\3.10.0\checker-qual-3.10.0.jar;D:\apache-maven-3.9.9\repository\com\google\errorprone\error_prone_an notations\2.2.0\error_prone_annotations-2.2.0.jar;D:\apache-maven-3.9.9\repository\com\google\j2objc\j2objc-annotations\1.1\j2objc-annotations-1.1.jar;D:\apache-maven-3.9.9\repository\org\codehaus\mojo\animal-sniffer-annotations\1.17\animal-sniffer-annotations-1.17.jar;D:\apache-maven-3.9.9\repository\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;D:\apache-maven-3.9.9\repository\org\apache\logging\log4j\log4j-slf4j-impl\2.17.1\log4j-slf4j-impl-2.17.1.jar;D:\apache-maven-3.9.9\repository\org\apache\logging\log4j\log4j-api\2.17.1\log4j-api-2.17.1.jar;D:\apache-maven-3.9.9\repository\org\apache\logging\log4j\log4j-core\2.17.1\log4j-core-2.17.1.jar;D:\apache-maven-3.9.9\repository\org\slf4j\jcl-over-slf4j\1.7.25\jcl-over-slf4j-1.7.25.jar;D:\apache-maven-3.9.9\repository\org\apache\logging\log4j\log4j-1.2-api\2.17.1\log4j-1.2-api-2.17.1.jar;D:\apache-maven-3.9.9\repository\org\objenesis\objenesis\3.3\objenesis-3.3.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient\0.16.0\s impleclient-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_tracer_otel\0.16.0\simpleclient_tracer_otel-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_tracer_common\0.16.0\simpleclient_tracer_common-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_tracer_otel_agent\0.16.0\simpleclient_tracer_otel_agent-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_hotspot\0.16.0\simpleclient_hotspot-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_httpserver\0.16.0\simpleclient_httpserver-0.16.0.jar;D:\apache-maven-3.9.9\repository\io\prometheus\simpleclient_common\0.16.0\simpleclient_common-0.16.0.jar org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample 2024-12-31 15:41:50,331 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Loading config file from path: D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-examples\seatunnel-flink-connector-v2-example\target\classes\examples\mysql_to_sr.conf 2024-12-31 15:41:50,437 INFO org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade spi: [base64] 2024-12-31 15:41:50,719 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: { "transform" : [], "sink" : [ { "base-url" : "jdbc:mysql://10.96.9.163:9030/market_new_dw", "database" : "market_new_dw", "password" : "******", "batch_max_rows" : 10240, "nodeUrls" : [ "10.96.9.163:8040" ], "source_table_name" : "t_electronic_back_order", "plugin_name" : "StarRocks", "table" : "t_electronic_back_order_st", "username" : "******" } ], "source" : [ { "password" : "******", "driver" : "com.mysql.cj.jdbc.Driver", "parallelism" : 2, "query" : "SELECT `id`, `order_code`, `status`, `create_date`, `order_total_price`, `order_pay_mode`, `old_order_code`, `actual_money`, `operate_flag`, `order_commodity_weight`, `cabinet_name`, `cabinet_code`FROM `market_new2`.`t_electronic_back_order`", "result_table_name" : "t_electronic_back_order", "partition_column" : "id", "plugin_name" : "Jdbc", "user" : "root", "url" : "jdbc:mysql://58.34.53.226:23306/market_new2?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useSSL=false", "partition_num" : "10" } ], "env" : { "job.mode" : "BATCH", "job.name" : "SeaTunnel_market_new_58_163_sr_Job", "checkpoint.interval" : 10000 } } 2024-12-31 15:41:50,965 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:50,967 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load Factory Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:50,998 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} from classpath 2024-12-31 15:41:51,324 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils - Loading catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog 2024-12-31 15:41:51,324 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog - Catalog MySQL established connection to jdbc:mysql://58.34.53.226:23306/market_new2?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useSSL=false 2024-12-31 15:41:51,386 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils - Loaded 1 catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog 2024-12-31 15:41:51,390 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog - Catalog MySQL closing 2024-12-31 15:41:51,393 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load Factory Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:51,394 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelTransform Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:51,396 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load Factory Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:51,396 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:51,398 WARN org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Remove invalid jar when inject jars into config: file:/D:/2025/bigdata/apache-seatunnel-2.3.8-src/seatunnel-common/starter/seatunnel-flink-15-starter.jar 2024-12-31 15:41:51,399 WARN org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Remove invalid jar when inject jars into config: file:/D:/2025/bigdata/apache-seatunnel-2.3.8-src/seatunnel-common/starter/seatunnel-flink-15-starter.jar 2024-12-31 15:41:51,494 WARN org.apache.seatunnel.core.starter.flink.execution.AbstractFlinkRuntimeEnvironment - Disabled Checkpointing. In flink execution environment, checkpointing is not supported and not needed when executing jobs in BATCH mode 2024-12-31 15:41:51,553 INFO org.apache.flink.api.java.typeutils.TypeExtractor - class org.apache.seatunnel.api.table.type.SeaTunnelRow does not contain a setter for field fields 2024-12-31 15:41:51,553 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class class org.apache.seatunnel.api.table.type.SeaTunnelRow cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance. 2024-12-31 15:41:51,583 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from D:\2025\bigdata\apache-seatunnel-2.3.8-src\seatunnel-common\connectors 2024-12-31 15:41:51,587 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 2024-12-31 15:41:51,587 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, 2024-12-31 15:41:51,587 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-12-31 15:41:51,587 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:Flink job executed failed 2024-12-31 15:41:51,589 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: Flink job executed failed at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:63) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:39) Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='StarRocks'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:237) at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:177) at org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.fallbackCreateSink(SinkExecuteProcessor.java:203) at org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.execute(SinkExecuteProcessor.java:114) at org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.execute(FlinkExecution.java:115) at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:61) ... 2 more 2024-12-31 15:41:51,590 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: Flink job executed failed at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:63) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:39) Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='StarRocks'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:237) at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:177) at org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.fallbackCreateSink(SinkExecuteProcessor.java:203) at org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.execute(SinkExecuteProcessor.java:114) at org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.execute(FlinkExecution.java:115) at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:61) ... 2 more Process finished with exit code 1 ``` ### Zeta or Flink or Spark Version 11 ### Java or Scala Version 11 ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
