search

itinycheng / flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Apache License 2.0
363 stars 154 forks source link

我使用sql连接clickhouse查询的时候也出现了java.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchInputFormat #111

Closed zenoprod closed 10 months ago

zenoprod commented 10 months ago

log.txt bao报错如上，和#96问题类似，可以麻烦看下是什么错误嘛， 补充信息：我是使用的flink sql-client进行测试的，我在添加jar包后重启cluster后还是报错 ./bin/start-cluster.sh ./bin/sql-client.sh

zenoprod commented 10 months ago 

CREATE TABLE test_rightTable (
    `a` STRING,
    `b` INTEGER
) WITH (
  'connector' = 'clickhouse',
  'url' = 'clickhouse://***:8123',
  'database-name' = 'test',
  'username' = 'default',
  'password' = '***',
  'table-name' = 'test'
);
``` 我的DDL语句如上