Comments (5)
例如: clickhouse://host1:8123,host2:8123,host3:8123
您好,支持:
具体实现使用的是clickhouse-jdbc
中的BalancedClickhouseDataSource
from flink-connector-clickhouse.
@itinycheng 多谢,我测试一下看看
from flink-connector-clickhouse.
您好,我在flink sql中测试集群模式的url,结果失败了
输入的url是
CREATE TABLE (
略
) WITH (
'connector' = 'clickhouse',
'url' = 'clickhouse://192.168.0.1:30004,192.168.0.2:30004,192.168.0.3:30004',
其他参数略
)
调试得到的url是clickhouse://null
INFO org.apache.flink.connector.clickhouse.internal.connection.ClickHouseConnectionProvider [] - connecting to clickhouse://null, database gaofang
我猜测是org.apache.flink.configuration.ReadableConfig
读取url的时候,如果遇到逗号分隔会存在异常。
明天我在调试一下,如果有结果的话,我提交一个PR修复一下
如果您能给出一些指导,那就更好不过啦 :)
另外搜索到两个相关问题的链接:
ClickHouse/clickhouse-java#678
https://issues.apache.org/jira/browse/FLINK-17294
from flink-connector-clickhouse.
是因为我有一个自定义的Properties文件弄错了,所以读取到的为null。 😂
flink sql 1.15.1,测试集群模式url是没问题的。
from flink-connector-clickhouse.
是因为我有一个自定义的Properties文件弄错了,所以读取到的为null。 😂
flink sql 1.15.1,测试集群模式url是没问题的。
好的,有遇到问题,欢迎PR 🤝;
from flink-connector-clickhouse.
Related Issues (20)
- Add Apache Listen to File hard
- sink exception e.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat HOT 3
- how to pack a fat jar HOT 1
- 有人编译成功么,可以分享下么 HOT 1
- 使用flink 版本是1.19 flink cdc 时报错了,应该是序列化的问题 Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat HOT 4
- Support URLs with query params HOT 3
- Add issues And pull template to project
- [Bug]: Unit test error cause CI building failure
- [Bug]: not set Clickhouse userName and password have npe
- [Bug]: UInt Type Not Supprot to Read Or Write HOT 2
- [Feature]: Add Flink Clickhouse QuickStart For Read Or Write Data
- [Feature]: Support Unit5 Test For Clickhouse Connector
- flink1.17.2 clickhouse catalog集成kafka 报错:创建kafka表时报错 HOT 2
- [Bug]: 经常出现刷新异常 HOT 4
- [Enhance]: Ensure Consistency of Database and Parameters in Newly Created ClickHouse JDBC Connections HOT 2
- [Bug]: 发现除了insert,update和delete操作都无法正常同步
- 请问支持flinkCDC3.0的pipline同步方式吗 HOT 1
- 读取速度似乎很慢,资源似乎不能得到有效利用[Bug]: HOT 2
- [Bug]: When flink specifies sink parallelism, does it have to specify the primary key?
- 支持 URL后面添加socket_timeout?
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from flink-connector-clickhouse.