zhangwen0527 commented on issue #12765:
URL: https://github.com/apache/seatunnel/issues/12765#issuecomment-6185614240
apache-seatunnel-3.0.0 版本
ClickHouse 26.9.9.28 版本
配置文件：clienthouse_to_es.config
env {
parallelism = 4
job.mode = "BATCH"
checkpoint.interval = 10000
}
source {
Clickhouse {
host = "127.0.0.1:8123"
username = "admin"
password = "*******"
database = "hy_vector"
sql = "SELECT
uuid,camera_id,target_img,target_scene,target_desc,cluster_id,target_vector,take_time,create_time,clear_score,person_vector,src_type
FROM hy_vector.t_vector"
batch_size = 3000
clickhouse.config = {
"socket_timeout": "300000"
}
}
}
sink {
Elasticsearch {
hosts = ["https://127.0.0.1:9200";]
index = "t_vector1"
username = "elastic"
password = "******"
auth_type = "basic"
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode = "APPEND_DATA"
primary_keys = ["uuid"]
max_batch_size = 3000
max_retry_count = 3
}
}
jdk: openjdk version "11" 2018-09-25
OpenJDK Runtime Environment 18.9 (build 11+28)
OpenJDK 64-Bit Server VM 18.9 (build 11+28, mixed mode)
连接目录
root@xincheng-AS4105G-D12R-G3:/mnt/apache-seatunnel-3.0.0# ll connectors/
总计 3048320
drwxr-xr-x 2 root root 12288 10月 15 13:57 ./
drwxr-xr-x 11 root root 4096 11月 9 2023 ../
-rw-r--r-- 1 root root 1895628 10月 14 11:05 connector-activemq-3.0.0.jar
-rw-r--r-- 1 root root 4027686 10月 14 10:57 connector-aerospike-3.0.0.jar
-rw-r--r-- 1 root root 2560579 10月 14 10:57
connector-amazondocumentdb-3.0.0.jar
-rw-r--r-- 1 root root 13602287 10月 14 10:57
connector-amazondynamodb-3.0.0.jar
-rw-r--r-- 1 root root 10967733 10月 14 11:04 connector-amazonsqs-3.0.0.jar
-rw-r--r-- 1 root root 390424 10月 14 10:57 connector-assert-3.0.0.jar
-rw-r--r-- 1 root root 21786767 10月 14 10:57
connector-azurecosmosdb-3.0.0.jar
-rw-r--r-- 1 root root 18952156 10月 14 11:00
connector-azure-queue-storage-3.0.0.jar
-rw-r--r-- 1 root root 52519211 10月 14 11:06 connector-bigquery-3.0.0.jar
-rw-r--r-- 1 root root 14610269 10月 14 10:57 connector-cassandra-3.0.0.jar
-rw-r--r-- 1 root root 27897476 11月 9 2023 connector-cdc-base-3.0.0.jar
-rw-r--r-- 1 root root 12413791 10月 14 10:57 connector-cdc-db2-3.0.0.jar
-rw-r--r-- 1 root root 6673010 10月 14 10:57
connector-cdc-mongodb-3.0.0.jar
-rw-r--r-- 1 root root 22269725 10月 14 10:57 connector-cdc-mysql-3.0.0.jar
-rw-r--r-- 1 root root 15340938 10月 14 11:05
connector-cdc-opengauss-3.0.0.jar
-rw-r--r-- 1 root root 31590975 10月 14 10:58 connector-cdc-oracle-3.0.0.jar
-rw-r--r-- 1 root root 14375278 10月 14 10:58
connector-cdc-postgres-3.0.0.jar
-rw-r--r-- 1 root root 12484442 10月 14 10:57
connector-cdc-sqlserver-3.0.0.jar
-rw-r--r-- 1 root root 12319832 10月 14 10:58 connector-cdc-tidb-3.0.0.jar
-rw-r--r-- 1 root root 30306573 10月 14 10:58 connector-cdc-vitess-3.0.0.jar
-rw-r--r-- 1 root root 33518841 10月 14 10:58 connector-clickhouse-3.0.0.jar
-rw-r--r-- 1 root root 238530 11月 9 2023 connector-console-3.0.0.jar
-rw-r--r-- 1 root root 30353847 10月 14 11:03 connector-couchbase-3.0.0.jar
-rw-r--r-- 1 root root 8439020 10月 14 10:58 connector-databend-3.0.0.jar
-rw-r--r-- 1 root root 10345852 10月 14 10:58 connector-datahub-3.0.0.jar
-rw-r--r-- 1 root root 1696563 10月 14 11:05 connector-deeplake-3.0.0.jar
-rw-r--r-- 1 root root 5759647 10月 14 10:58 connector-dingtalk-3.0.0.jar
-rw-r--r-- 1 root root 3782048 10月 14 10:58 connector-doris-3.0.0.jar
-rw-r--r-- 1 root root 114055493 10月 14 11:04 connector-druid-3.0.0.jar
-rw-r--r-- 1 root root 19980219 10月 14 11:05 connector-easysearch-3.0.0.jar
-rw-r--r-- 1 root root 6320097 10月 14 11:04
connector-edge-socket-3.0.0.jar
-rw-r--r-- 1 root root 5760908 10月 14 10:58
connector-elasticsearch-3.0.0.jar
-rw-r--r-- 1 root root 916068 10月 14 10:58 connector-email-3.0.0.jar
-rw-r--r-- 1 root root 4623083 10月 14 11:00
connector-facebook-ads-3.0.0.jar
-rw-r--r-- 1 root root 396899 11月 9 2023 connector-fake-3.0.0.jar
-rw-r--r-- 1 root root 63627385 10月 14 11:00 connector-file-bos-3.0.0.jar
-rw-r--r-- 1 root root 63627385 10月 14 10:58 connector-file-cos-3.0.0.jar
-rw-r--r-- 1 root root 63733846 10月 14 10:58 connector-file-ftp-3.0.0.jar
-rw-r--r-- 1 root root 102311748 10月 14 10:59 connector-file-gcs-3.0.0.jar
-rw-r--r-- 1 root root 63717285 10月 14 10:59
connector-file-hadoop-3.0.0.jar
-rw-r--r-- 1 root root 63114027 10月 14 10:59
connector-file-jindo-oss-3.0.0.jar
-rw-r--r-- 1 root root 63715103 10月 14 10:59 connector-file-local-3.0.0.jar
-rw-r--r-- 1 root root 93234294 10月 14 11:00 connector-file-obs-3.0.0.jar
-rw-r--r-- 1 root root 63716082 10月 14 10:59 connector-file-oss-3.0.0.jar
-rw-r--r-- 1 root root 63728702 10月 14 10:59 connector-file-s3-3.0.0.jar
-rw-r--r-- 1 root root 64281270 10月 14 10:59 connector-file-sftp-3.0.0.jar
-rw-r--r-- 1 root root 5932300 10月 14 11:00 connector-firebase-3.0.0.jar
-rw-r--r-- 1 root root 68116815 10月 14 11:00 connector-fluss-3.0.0.jar
-rw-r--r-- 1 root root 4627713 10月 14 11:00 connector-google-ads-3.0.0.jar
-rw-r--r-- 1 root root 49147110 10月 14 11:00
connector-google-bigtable-3.0.0.jar
-rw-r--r-- 1 root root 47106291 10月 14 11:00
connector-google-firestore-3.0.0.jar
-rw-r--r-- 1 root root 44036722 10月 14 11:00
connector-google-pubsub-3.0.0.jar
-rw-r--r-- 1 root root 7237869 10月 14 11:00
connector-google-sheets-3.0.0.jar
-rw-r--r-- 1 root root 12548658 10月 14 11:01 connector-graphql-3.0.0.jar
-rw-r--r-- 1 root root 52097096 10月 14 11:04 connector-hbase-3.0.0.jar
-rw-r--r-- 1 root root 72556705 10月 14 11:01 connector-hive-3.0.0.jar
-rw-r--r-- 1 root root 5469003 10月 14 11:02
connector-http-airtable-3.0.0.jar
-rw-r--r-- 1 root root 5440371 10月 14 11:01 connector-http-base-3.0.0.jar
-rw-r--r-- 1 root root 5444661 10月 14 11:01
connector-http-feishu-3.0.0.jar
-rw-r--r-- 1 root root 5447972 10月 14 11:01
connector-http-github-3.0.0.jar
-rw-r--r-- 1 root root 5448022 10月 14 11:01
connector-http-gitlab-3.0.0.jar
-rw-r--r-- 1 root root 5447291 10月 14 11:01 connector-http-jira-3.0.0.jar
-rw-r--r-- 1 root root 5448185 10月 14 11:01
connector-http-klaviyo-3.0.0.jar
-rw-r--r-- 1 root root 5447935 10月 14 11:01
connector-http-lemlist-3.0.0.jar
-rw-r--r-- 1 root root 5446436 10月 14 11:01
connector-http-linear-3.0.0.jar
-rw-r--r-- 1 root root 5451297 10月 14 11:01
connector-http-myhours-3.0.0.jar
-rw-r--r-- 1 root root 5448018 10月 14 11:01
connector-http-notion-3.0.0.jar
-rw-r--r-- 1 root root 5448113 10月 14 11:01
connector-http-onesignal-3.0.0.jar
-rw-r--r-- 1 root root 5446881 10月 14 11:01
connector-http-persistiq-3.0.0.jar
-rw-r--r-- 1 root root 5454293 10月 14 11:02
connector-http-posthog-3.0.0.jar
-rw-r--r-- 1 root root 5447424 10月 14 11:02
connector-http-shopify-3.0.0.jar
-rw-r--r-- 1 root root 5458157 10月 14 11:01
connector-http-stripe-3.0.0.jar
-rw-r--r-- 1 root root 5449118 10月 14 11:02
connector-http-wechat-3.0.0.jar
-rw-r--r-- 1 root root 5458463 10月 14 11:02
connector-http-zendesk-3.0.0.jar
-rw-r--r-- 1 root root 162995551 10月 14 11:02 connector-hudi-3.0.0.jar
-rw-r--r-- 1 root root 16752398 10月 14 11:06 connector-hugegraph-3.0.0.jar
-rw-r--r-- 1 root root 55287799 10月 14 11:02 connector-iceberg-3.0.0.jar
-rw-r--r-- 1 root root 3983660 10月 14 11:02 connector-influxdb-3.0.0.jar
-rw-r--r-- 1 root root 5971904 10月 14 11:02 connector-iotdb-3.0.0.jar
-rw-r--r-- 1 root root 23356893 10月 14 11:02 connector-iotdb-v2-3.0.0.jar
-rw-r--r-- 1 root root 12266577 10月 14 11:02 connector-jdbc-3.0.0.jar
-rw-r--r-- 1 root root 33360540 10月 14 11:03 connector-kafka-3.0.0.jar
-rw-r--r-- 1 root root 56884776 10月 14 11:03 connector-kudu-3.0.0.jar
-rw-r--r-- 1 root root 283364276 10月 14 11:06 connector-lance-3.0.0.jar
-rw-r--r-- 1 root root 86562079 10月 14 11:03 connector-maxcompute-3.0.0.jar
-rw-r--r-- 1 root root 5451552 10月 14 11:01 connector-mem0-3.0.0.jar
-rw-r--r-- 1 root root 27899435 10月 14 11:05 connector-milvus-3.0.0.jar
-rw-r--r-- 1 root root 2649998 10月 14 11:03 connector-mongodb-3.0.0.jar
-rw-r--r-- 1 root root 610131 10月 14 11:06 connector-mqtt-3.0.0.jar
-rw-r--r-- 1 root root 6761530 10月 14 11:06
connector-nats-jetstream-3.0.0.jar
-rw-r--r-- 1 root root 7031542 10月 14 11:03
connector-nebulagraph-3.0.0.jar
-rw-r--r-- 1 root root 5270614 10月 14 11:03 connector-neo4j-3.0.0.jar
-rw-r--r-- 1 root root 148981713 10月 14 11:03 connector-openmldb-3.0.0.jar
-rw-r--r-- 1 root root 69965765 10月 14 11:05 connector-paimon-3.0.0.jar
-rw-r--r-- 1 root root 10071279 10月 14 11:05 connector-prometheus-3.0.0.jar
-rw-r--r-- 1 root root 47911935 10月 14 11:03 connector-pulsar-3.0.0.jar
-rw-r--r-- 1 root root 271993 10月 14 11:06 connector-python-3.0.0.jar
-rw-r--r-- 1 root root 24996437 10月 14 11:05 connector-qdrant-3.0.0.jar
-rw-r--r-- 1 root root 16479213 10月 14 11:04 connector-rabbitmq-3.0.0.jar
-rw-r--r-- 1 root root 1631734 10月 14 11:04 connector-redis-3.0.0.jar
-rw-r--r-- 1 root root 15416426 10月 14 11:05 connector-rocketmq-3.0.0.jar
-rw-r--r-- 1 root root 72825605 10月 14 11:04
connector-s3-redshift-3.0.0.jar
-rw-r--r-- 1 root root 4695503 10月 14 10:57 connector-salesforce-3.0.0.jar
-rw-r--r-- 1 root root 1860661 10月 14 11:04
connector-selectdb-cloud-3.0.0.jar
-rw-r--r-- 1 root root 43233010 10月 14 11:05
connector-sensorsdata-3.0.0.jar
-rw-r--r-- 1 root root 808934 10月 14 11:04 connector-sentry-3.0.0.jar
-rw-r--r-- 1 root root 6117940 10月 14 11:04 connector-slack-3.0.0.jar
-rw-r--r-- 1 root root 10915481 10月 14 11:05 connector-sls-3.0.0.jar
-rw-r--r-- 1 root root 805168 10月 14 11:06 connector-snmp-3.0.0.jar
-rw-r--r-- 1 root root 358573 10月 14 11:04 connector-socket-3.0.0.jar
-rw-r--r-- 1 root root 3495979 10月 14 11:04 connector-starrocks-3.0.0.jar
-rw-r--r-- 1 root root 11189276 10月 14 11:04 connector-tablestore-3.0.0.jar
-rw-r--r-- 1 root root 5721617 10月 14 11:05 connector-tdengine-3.0.0.jar
-rw-r--r-- 1 root root 1829311 10月 14 11:00 connector-tiktok-ads-3.0.0.jar
-rw-r--r-- 1 root root 6109266 10月 14 11:05 connector-typesense-3.0.0.jar
-rw-r--r-- 1 root root 15589272 10月 14 11:05 connector-web3j-3.0.0.jar
-rw-r--r-- 1 root root 9440 11月 9 2023 plugin-mapping.properties
执行的：bin/seatunnel.sh --config ./config/clienthouse_to_es.config -m local
输出信息：WARNING: sun.reflect.Reflection.getCallerClass is not supported. This
will impact performance.
2026-10-15 13:59:49,843 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration '/mnt/apache-seatunnel-3.0.0/config/seatunnel.yaml' from
System property 'seatunnel.config'
2026-10-15 13:59:49,849 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at /mnt/apache-seatunnel-3.0.0/config/seatunnel.yaml
2026-10-15 13:59:49,853 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] -
seatunnel.home is /mnt/apache-seatunnel-3.0.0
2026-10-15 13:59:49,981 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-10-15 13:59:49,982 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration '/mnt/apache-seatunnel-3.0.0/config/hazelcast.yaml' from
System property 'hazelcast.config'
2026-10-15 13:59:49,982 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at /mnt/apache-seatunnel-3.0.0/config/hazelcast.yaml
2026-10-15 13:59:50,493 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/mnt/apache-seatunnel-3.0.0/config/hazelcast-client.yaml' from System property
'hazelcast.client.config'
2026-10-15 13:59:50,493 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/mnt/apache-seatunnel-3.0.0/config/hazelcast-client.yaml
2026-10-15 13:59:50,528 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Local mode REST config: enableHttp=true, port=8080, enableHttps=false,
httpsPort=8443
2026-10-15 13:59:50,547 WARN [h.i.i.HazelcastInstanceFactory] [main] -
Hazelcast is starting in a Java modular environment (Java 9 and newer) but
without proper access to required Java packages. Use additional Java arguments
to provide Hazelcast access to Java internal API. The internal API access is
used to get the best performance results. Arguments to be used:
--add-modules java.se --add-exports java.base/jdk.internal.ref=ALL-UNNAMED
--add-opens java.base/java.lang=ALL-UNNAMED --add-opens
java.base/sun.nio.ch=ALL-UNNAMED --add-opens
java.management/sun.management=ALL-UNNAMED --add-opens
jdk.management/com.sun.management.internal=ALL-UNNAMED
2026-10-15 13:59:50,613 WARN [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-672582] [5.1] You configured your member address as host
name. Please be aware of that your dns can be spoofed. Make sure that your dns
configurations are correct.
2026-10-15 13:59:50,613 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-672582] [5.1] Resolving domain name 'localhost' to
address(es): [127.0.0.1]
2026-10-15 13:59:50,614 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-672582] [5.1] Interfaces is disabled, trying to pick one
address from TCP-IP config addresses: [localhost/127.0.0.1]
2026-10-15 13:59:50,703 INFO [o.a.s.e.s.SeaTunnelServer ] [main] -
SeaTunnel server start...
2026-10-15 13:59:50,708 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Based on Hazelcast IMDG version:
5.1.0 (20220228 - 21f20e7)
2026-10-15 13:59:50,708 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Cluster name: seatunnel-672582
2026-10-15 13:59:50,708 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1]
_____ _____ _
/ ___| |_ _| | |
\ `--. ___ __ _ | | _ _ _ __ _ __ ___ | |
`--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| |
/\__/ /| __/| (_| | | | | |_| || | | || | | || __/| |
\____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_|
2026-10-15 13:59:50,709 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Copyright © 2021-2024 The Apache
Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are
trademarks of The Apache Software Foundation.
2026-10-15 13:59:50,709 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Integrity Checker is disabled.
Fail-fast on corrupted executables will not be performed.
To enable integrity checker do one of the following:
- Change member config using Java API:
config.setIntegrityCheckerEnabled(true);
- Change XML/YAML configuration property: Set
hazelcast.integrity-checker.enabled to true
- Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast
embedded, works only when loading config via Config.load)
- Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended
when running container image. For Hazelcast embedded, works only when loading
config via Config.load)
2026-10-15 13:59:50,714 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] The Jet engine is disabled.
To enable the Jet engine on the members, do one of the following:
- Change member config using Java API:
config.getJetConfig().setEnabled(true)
- Change XML/YAML configuration property: Set hazelcast.jet.enabled to true
- Add system property: -Dhz.jet.enabled=true (for Hazelcast embedded,
works only when loading config via Config.load)
- Add environment variable: HZ_JET_ENABLED=true (recommended when running
container image. For Hazelcast embedded, works only when loading config via
Config.load)
2026-10-15 13:59:51,291 INFO [c.h.s.security ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Enable DEBUG/FINE log level for log
category com.hazelcast.system.security or use
-Dhazelcast.security.recommendations system property to see 🔒 security
recommendations and the status of current config.
2026-10-15 13:59:51,480 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSource Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,493 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,504 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelTransform Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,535 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSource Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,541 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,544 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelTransform Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:51,548 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] -
Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery
2026-10-15 13:59:51,551 WARN [c.h.c.CPSubsystem ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] CP Subsystem is not enabled. CP data
structures will operate in UNSAFE mode! Please note that UNSAFE mode will not
provide strong consistency guarantees.
2026-10-15 13:59:51,849 INFO [.c.c.DefaultClassLoaderService] [main] -
start classloader service with cache mode
2026-10-15 13:59:51,860 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration '/mnt/apache-seatunnel-3.0.0/config/seatunnel.yaml' from
System property 'seatunnel.config'
2026-10-15 13:59:51,860 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at /mnt/apache-seatunnel-3.0.0/config/seatunnel.yaml
2026-10-15 13:59:51,867 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-10-15 13:59:51,867 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration '/mnt/apache-seatunnel-3.0.0/config/hazelcast.yaml' from
System property 'hazelcast.config'
2026-10-15 13:59:51,868 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at /mnt/apache-seatunnel-3.0.0/config/hazelcast.yaml
2026-10-15 13:59:51,881 WARN [o.a.s.e.s.TaskExecutionService]
[pool-3-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1] The Node is not
ready yet, Node state STARTING,looking forward to the next scheduling
2026-10-15 13:59:51,884 INFO [o.a.s.e.s.TaskExecutionService] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Created new BusWork : 822815599
2026-10-15 13:59:51,902 WARN [a.s.e.s.s.s.DefaultSlotService]
[hz.main.seaTunnel.slotService.thread] - failed send heartbeat to resource
manager, will retry later. this address: [localhost]:5801
2026-10-15 13:59:52,170 WARN [o.a.h.u.NativeCodeLoader ] [main] -
Unable to load native-hadoop library for your platform... using builtin-java
classes where applicable
log4j:WARN No appenders could be found for logger
(org.apache.htrace.core.Tracer).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
2026-10-15 13:59:52,494 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 0
corePoolSize : 10
maximumPoolSize : 2147483647
poolSize : 0
completedTaskCount : 0
taskCount : 0
***********************************************
2026-10-15 13:59:52,505 INFO [o.a.s.e.s.JettyService ] [main] -
SeaTunnel REST service will start on port 8080
2026-10-15 13:59:52,522 INFO [o.a.s.s.o.e.j.u.log ] [main] -
Logging initialized @3977ms to
org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog
2026-10-15 13:59:52,628 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Empty contextPath
2026-10-15 13:59:52,722 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSource Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:52,728 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:52,735 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelTransform Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:52,747 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
jetty-9.4.56.v20240826; built: 2024-08-26T17:15:05.868Z; git:
ec6782ff5ead824dabdcf47fa98f90a4aedff401; jvm 11+28
2026-10-15 13:59:52,800 INFO [o.a.s.s.o.e.j.s.session ] [main] -
DefaultSessionIdManager workerName=node0
2026-10-15 13:59:52,800 INFO [o.a.s.s.o.e.j.s.session ] [main] - No
SessionScavenger set, using defaults
2026-10-15 13:59:52,803 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Scavenging every 600000ms
2026-10-15 13:59:52,994 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Started o.a.s.s.o.e.j.s.ServletContextHandler@6e46891d{/,null,AVAILABLE}
2026-10-15 13:59:53,011 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Started ServerConnector@4628a02b{HTTP/1.1, (http/1.1)}{0.0.0.0:8080}
2026-10-15 13:59:53,012 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
Started @4468ms
2026-10-15 13:59:53,062 INFO [c.h.i.d.Diagnostics ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-10-15 13:59:53,069 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] [localhost]:5801 is STARTING
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by
com.hazelcast.internal.networking.nio.SelectorOptimizer
(file:/mnt/apache-seatunnel-3.0.0/starter/seatunnel-starter.jar) to field
sun.nio.ch.SelectorImpl.selectedKeys
WARNING: Please consider reporting this to the maintainers of
com.hazelcast.internal.networking.nio.SelectorOptimizer
WARNING: Use --illegal-access=warn to enable warnings of further illegal
reflective access operations
WARNING: All illegal access operations will be denied in a future release
2026-10-15 13:59:53,179 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5827 is added to the blacklist.
2026-10-15 13:59:53,179 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5806 is added to the blacklist.
2026-10-15 13:59:53,179 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5808 is added to the blacklist.
2026-10-15 13:59:53,179 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5829 is added to the blacklist.
2026-10-15 13:59:53,180 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5820 is added to the blacklist.
2026-10-15 13:59:53,180 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5813 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5814 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5810 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5815 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5818 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5821 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5816 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5825 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5823 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5811 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5805 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5828 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5802 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5826 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5803 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5804 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5809 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5817 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5812 is added to the blacklist.
2026-10-15 13:59:53,182 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5830 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5824 is added to the blacklist.
2026-10-15 13:59:53,181 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5807 is added to the blacklist.
2026-10-15 13:59:53,186 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-16] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5822 is added to the blacklist.
2026-10-15 13:59:53,187 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-672582] [5.1]
[localhost]:5819 is added to the blacklist.
2026-10-15 13:59:54,172 INFO [c.h.i.c.ClusterService ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1]
Members {size:1, ver:1} [
Member [localhost]:5801 - 2f3b9774-c9fa-4988-b0b0-a1a362195c05
[master node] [active master] this
]
2026-10-15 13:59:54,190 INFO [o.a.s.e.s.CoordinatorService ]
[pool-8-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1] This node become
a new active master node, begin init coordinator service
2026-10-15 13:59:54,196 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] [localhost]:5801 is STARTED
2026-10-15 13:59:54,263 INFO [o.a.s.e.s.CoordinatorService ]
[pool-8-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1] Loaded event
handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@3c307c69]
2026-10-15 13:59:54,266 INFO [.h.i.p.i.PartitionStateManager]
[pool-8-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1] Initializing
cluster partition table arrangement...
2026-10-15 13:59:54,279 INFO [.c.i.s.ClientInvocationService] [main] -
hz.client_1 [seatunnel-672582] [5.1] Running with 2 response threads,
dynamic=true
2026-10-15 13:59:54,356 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTING
2026-10-15 13:59:54,358 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTED
2026-10-15 13:59:54,373 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-672582] [5.1] Trying to connect to cluster:
seatunnel-672582
2026-10-15 13:59:54,377 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-672582] [5.1] Trying to connect to [localhost]:5801
2026-10-15 13:59:54,438 INFO [.p.t.AuthenticationMessageTask]
[hz.main.generic-operation.thread-0] - [localhost]:5801 [seatunnel-672582]
[5.1] Received auth from Connection[id=1, /127.0.0.1:5801->/127.0.0.1:54437,
qualifier=null, endpoint=[127.0.0.1]:54437,
remoteUuid=ac976195-e3db-4525-b56b-519aeddf4c0f, alive=true,
connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid:
ac976195-e3db-4525-b56b-519aeddf4c0f, client name: hz.client_1, client version:
5.1
2026-10-15 13:59:54,443 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_CONNECTED
2026-10-15 13:59:54,444 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-672582] [5.1] Authenticated with server
[localhost]:5801:2f3b9774-c9fa-4988-b0b0-a1a362195c05, server version: 5.1,
local address: /127.0.0.1:54437
2026-10-15 13:59:54,446 INFO [c.h.i.d.Diagnostics ] [main] -
hz.client_1 [seatunnel-672582] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-10-15 13:59:54,462 INFO [c.h.c.i.s.ClientClusterService]
[hz.client_1.event-6] - hz.client_1 [seatunnel-672582] [5.1]
Members [1] {
Member [localhost]:5801 - 2f3b9774-c9fa-4988-b0b0-a1a362195c05
[master node]
}
2026-10-15 13:59:54,508 INFO [.c.i.s.ClientStatisticsService] [main] -
Client statistics is enabled with period 5 seconds.
2026-10-15 13:59:54,518 INFO [o.a.s.e.s.CoordinatorService ]
[pool-8-thread-1] - [localhost]:5801 [seatunnel-672582] [5.1] Start pending job
schedule thread
2026-10-15 13:59:54,610 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Loading config file from path: ./config/clienthouse_to_es.config
2026-10-15 13:59:54,726 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load
config shade spi: [base64]
2026-10-15 13:59:54,796 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Parsed config file:
{
"env" : {
"parallelism" : 4,
"job.mode" : "BATCH",
"checkpoint.interval" : 10000
},
"source" : [
{
"host" : "127.0.0.1:8123",
"username" : "******",
"password" : "******",
"database" : "hy_vector",
"sql" : "SELECT
uuid,camera_id,target_img,target_scene,target_desc,cluster_id,target_vector,take_time,create_time,clear_score,person_vector,src_type
FROM hy_vector.t_vector",
"batch_size" : 3000,
"clickhouse.config" : {
"socket_timeout" : "300000"
},
"plugin_name" : "Clickhouse"
}
],
"sink" : [
{
"hosts" : [
"https://127.0.0.1:9200";
],
"index" : "t_vector1",
"username" : "******",
"password" : "******",
"auth_type" : "basic",
"schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST",
"data_save_mode" : "APPEND_DATA",
"primary_keys" : [
"uuid"
],
"max_batch_size" : 3000,
"max_retry_count" : 3,
"plugin_name" : "Elasticsearch"
}
],
"transform" : []
}
2026-10-15 13:59:54,820 INFO [p.MultipleTableJobConfigParser] [main] - add
common jar in plugins :[]
2026-10-15 13:59:54,829 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSource Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:54,834 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Clickhouse'} at:
[file:/mnt/apache-seatunnel-3.0.0/connectors/connector-clickhouse-3.0.0.jar]
2026-10-15 13:59:54,835 INFO [.s.p.d.AbstractPluginDiscovery] [main] - find
connector jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Clickhouse'}:
[file:/mnt/apache-seatunnel-3.0.0/connectors/connector-clickhouse-3.0.0.jar]
2026-10-15 13:59:54,842 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelTransform Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:54,850 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /mnt/apache-seatunnel-3.0.0/connectors
2026-10-15 13:59:54,852 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Elasticsearch'} at:
[file:/mnt/apache-seatunnel-3.0.0/connectors/connector-elasticsearch-3.0.0.jar]
2026-10-15 13:59:54,852 INFO [.s.p.d.AbstractPluginDiscovery] [main] - find
connector jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Elasticsearch'}:
[file:/mnt/apache-seatunnel-3.0.0/connectors/connector-elasticsearch-3.0.0.jar]
2026-10-15 13:59:54,858 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all sources.
2026-10-15 13:59:55,435 ERROR [c.c.d.ClickHouseStreamResponse]
[ClickHouseClientWorker1] - Failed to create stream response, closing input
stream
2026-10-15 13:59:55,451 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTTING_DOWN
2026-10-15 13:59:55,458 INFO [c.h.i.s.t.TcpServerConnection ]
[hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-672582] [5.1]
Connection[id=1, /127.0.0.1:5801->/127.0.0.1:54437, qualifier=null,
endpoint=[127.0.0.1]:54437, remoteUuid=ac976195-e3db-4525-b56b-519aeddf4c0f,
alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection
closed by the other side
2026-10-15 13:59:55,459 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-672582] [5.1] Removed connection to endpoint:
[localhost]:5801:2f3b9774-c9fa-4988-b0b0-a1a362195c05, connection:
ClientConnection{alive=false, connectionId=1,
channel=NioChannel{/127.0.0.1:54437->localhost/127.0.0.1:5801},
remoteAddress=[localhost]:5801, lastReadTime=2026-10-15 13:59:54.601,
lastWriteTime=2026-10-15 13:59:54.599, closedTime=2026-10-15 13:59:55.453,
connected server version=5.1}
2026-10-15 13:59:55,460 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_DISCONNECTED
2026-10-15 13:59:55,466 INFO [c.h.c.i.ClientEndpointManager ]
[hz.main.event-3] - [localhost]:5801 [seatunnel-672582] [5.1] Destroying
ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:54437,
qualifier=null, endpoint=[127.0.0.1]:54437,
remoteUuid=ac976195-e3db-4525-b56b-519aeddf4c0f, alive=false,
connectionType=JVM, planeIndex=-1],
clientUuid=ac976195-e3db-4525-b56b-519aeddf4c0f, clientName=hz.client_1,
authenticated=true, clientVersion=5.1, creationTime=1792043994427, latest
clientAttributes=lastStatisticsCollectionTime=1792043994508,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1792043994380,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=0,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=401.126953125,os.totalPhysicalMemorySize=0,os.totalSwapSpaceSize=0,runtime.availablePr
ocessors=64,runtime.freeMemory=209525240,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=5978,runtime.usedMemory=58910216,
labels=[]}
2026-10-15 13:59:55,470 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-672582] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTDOWN
2026-10-15 13:59:55,473 INFO [.s.a.m.MetadataProviderManager] [main] -
MetadataProvider closed
2026-10-15 13:59:55,474 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed SeaTunnel client......
2026-10-15 13:59:55,474 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] [localhost]:5801 is SHUTTING_DOWN
2026-10-15 13:59:55,480 INFO [c.h.i.p.i.MigrationManager ]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-672582] [5.1] Shutdown
request of Member [localhost]:5801 - 2f3b9774-c9fa-4988-b0b0-a1a362195c05
[master node] [active master] this is handled
2026-10-15 13:59:55,498 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Shutting down connection manager...
2026-10-15 13:59:55,505 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Shutting down node engine...
2026-10-15 13:59:55,537 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Stopped ServerConnector@4628a02b{HTTP/1.1, (http/1.1)}{0.0.0.0:8080}
2026-10-15 13:59:55,538 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Stopped scavenging
2026-10-15 13:59:55,540 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Stopped o.a.s.s.o.e.j.s.ServletContextHandler@6e46891d{/,null,STOPPED}
2026-10-15 13:59:55,549 INFO [.c.c.DefaultClassLoaderService] [main] -
close classloader service
2026-10-15 13:59:55,563 INFO [.s.a.m.MetadataProviderManager] [main] -
MetadataProvider closed
2026-10-15 13:59:55,563 INFO [o.a.s.e.s.EventService ]
[event-forwarder-0] - Event forward thread interrupted
2026-10-15 13:59:58,586 INFO [c.h.i.i.NodeExtension ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Destroying node NodeExtension.
2026-10-15 13:59:58,587 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] Hazelcast Shutdown is completed in
3108 ms.
2026-10-15 13:59:58,588 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-672582] [5.1] [localhost]:5801 is SHUTDOWN
2026-10-15 13:59:58,588 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed HazelcastInstance ......
2026-10-15 13:59:58,589 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2026-10-15 13:59:58,589 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2026-10-15 13:59:58,589 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2026-10-15 13:59:58,589 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2026-10-15 13:59:58,594 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Exception
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException:
SeaTunnel job executed failed
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:291)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:41)
Caused by: org.apache.seatunnel.api.table.factory.FactoryException:
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to
create a source for identifier 'Clickhouse'.
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:177)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:88)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createAndPrepareSource(MultipleTableJobConfigParser.java:458)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.lambda$parseSource$3(MultipleTableJobConfigParser.java:412)
at
org.apache.seatunnel.api.common.multitable.MultiTableFailureHelper.collectFailedTables(MultiTableFailureHelper.java:109)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:409)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:267)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:154)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:222)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:229)
... 2 more
Caused by:
org.apache.seatunnel.connectors.seatunnel.clickhouse.exception.ClickhouseConnectorException:
ErrorCode:[API-01], ErrorDescription:[Configuration item validate failed] -
PluginName: Clickhouse, PluginType: SOURCE, Message: Magic is not correct -
expect [-126] but got [-113], server ClickHouseNode
[uri=http://10.8.0.70:8123/hy_vector,
options={server_time_zone=Asia/Shanghai,socket_timeout=300000}]@-2069124571
at
org.apache.seatunnel.connectors.seatunnel.clickhouse.source.ClickhouseSourceFactory.createSource(ClickhouseSourceFactory.java:215)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:192)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:145)
... 11 more
2026-10-15 13:59:58,595 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
Exception in thread "main"
org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel
job executed failed
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:291)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:41)
Caused by: org.apache.seatunnel.api.table.factory.FactoryException:
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to
create a source for identifier 'Clickhouse'.
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:177)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:88)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createAndPrepareSource(MultipleTableJobConfigParser.java:458)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.lambda$parseSource$3(MultipleTableJobConfigParser.java:412)
at
org.apache.seatunnel.api.common.multitable.MultiTableFailureHelper.collectFailedTables(MultiTableFailureHelper.java:109)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:409)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:267)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:154)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:222)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:229)
... 2 more
Caused by:
org.apache.seatunnel.connectors.seatunnel.clickhouse.exception.ClickhouseConnectorException:
ErrorCode:[API-01], ErrorDescription:[Configuration item validate failed] -
PluginName: Clickhouse, PluginType: SOURCE, Message: Magic is not correct -
expect [-126] but got [-113], server ClickHouseNode
[uri=http://10.8.0.70:8123/hy_vector,
options={server_time_zone=Asia/Shanghai,socket_timeout=300000}]@-2069124571
at
org.apache.seatunnel.connectors.seatunnel.clickhouse.source.ClickhouseSourceFactory.createSource(ClickhouseSourceFactory.java:215)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:192)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:145)
... 11 more
--
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]
