New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

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

Closed

zenoprod opened this issue Nov 7, 2023 · 1 comment

zenoprod commented Nov 7, 2023 •

edited

Loading

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

zenoprod changed the title ~~我使用sql连接clickhousejava.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchInputFormat~~ 我使用sql连接clickhouse查询的时候也出现了java.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchInputFormat

Author

zenoprod commented Nov 7, 2023

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

zenoprod closed this as completed

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment