issues
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
347
stars
149
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
sink.flush-interval不生效
#44
smileLuckBoy
closed
8 months ago
10
Caused by: java.io.IOException: java.sql.SQLException: Attempt to execute batch failed, exhausted retry times = 3
#43
zjialin
closed
8 months ago
6
mysqlcdc同步到ck库的更新有问题
#42
fejxc
closed
8 months ago
2
hudi同步ck数据报错
#41
q443048756
closed
8 months ago
1
大佬请教几个问题
#40
v-qiunan
closed
10 months ago
15
e.displayText() = DB::Exception: Mutations are not supported by storage Distributed
#39
hehetown
closed
1 year ago
4
use options use-local:Unable to establish connection to ClickHouse
#38
hehetown
closed
1 year ago
2
不支持指定sink 算子
#37
v-qiunan
closed
1 year ago
3
请问此连接器能实现clickhouse cdc么
#36
yl-yue
closed
2 years ago
2
mysql数据 slink clickhouse
#35
zjialin
closed
2 years ago
1
查询clickhouse数据
#34
jetliu1711
closed
2 years ago
4
batch写入超过3次报错
#33
jetliu1711
closed
2 years ago
1
flink sql sink到clickhouse
#32
jetliu1711
closed
2 years ago
12
org.apache.flink.connector.clickhouse.internal.executor.ClickHouseExecutor - ClickHouse executeBatch error
#31
Princewjh
closed
8 months ago
1
作者是否有意更改新的clickhouse驱动地址,以及升级java依赖版本
#30
imiros
closed
2 years ago
2
maven package not found javac
#29
imiros
closed
2 years ago
3
The clickhouse exception stack can only be viewed in the taskmanager log
#28
v-qiunan
closed
2 years ago
3
mysql-cdc to clickhous update 报错
#27
zjialin
closed
8 months ago
1
ClickHouse executeBatch error
#26
kongyuan1990
closed
2 years ago
7
Clickhouse source will pull up all of the table data when the job start, TM will crash down if table data too big
#25
LinhaiXu
closed
2 years ago
3
two table join in flink sink to clickhouse, update old data in mysql, it will delete this row in clickhouse and no insert
#24
xuanzhi201111
closed
8 months ago
10
How to support ClickHouse source in branch 1.12 ?
#23
LinhaiXu
closed
2 years ago
2
upsert by updating row if it exists and inserting otherwise
#22
wangqinghuan
closed
2 years ago
2
多并行度读取重复数据问题
#21
clisho
closed
2 years ago
5
How to guarantee exactly-once semantics?
#20
LuPan2015
closed
2 years ago
1
Update operation exception
#19
niuhuaian
closed
2 years ago
1
How can I set the synchronization when MySQL table structure or data changes?
#18
mjp27258
closed
2 years ago
1
The db history topic is missing. You may attempt to recover it by reconfiguring the connector to SCHEMA_ONLY_RECOVERY
#17
mjp27258
closed
2 years ago
2
同步mysql数据造成了mysql flush tables with read lock锁全表问题
#16
mjp27258
closed
2 years ago
2
mysql--> flink-1.13.5 bin/sql-client.sh ->clickhouse
#15
ADingDing
closed
2 years ago
1
Update to Flink 1.14.x
#14
snuyanzin
closed
2 years ago
1
Replace deprecated TableSchema with ResolvedSchema
#13
snuyanzin
closed
8 months ago
0
Refactor the code to use AbstractDialect
#12
snuyanzin
closed
8 months ago
3
Add mvnw and Github actions
#11
snuyanzin
closed
2 years ago
1
Add java example
#10
snuyanzin
closed
2 years ago
0
Maven Dependency
#9
qiangtoudianyan
closed
2 years ago
2
Use ResolvedSchema instead of deprecated TableSchema
#8
snuyanzin
closed
2 years ago
1
sink.ignore-delete
#7
dulangMaster
closed
2 years ago
2
It doesn't work with Flink 1.14.0
#6
shouxinjk
closed
2 years ago
3
append-only executor ignore UPDATE event
#5
liyubin117
closed
2 years ago
0
cast(timestamp as timestamp with local time zone) return the same value as input arg
#4
liyubin117
closed
2 years ago
1
flink字段time,ck字段datetime,写入报错
#3
liyubin117
closed
2 years ago
7
why ClickHouseBatchExecutor#addToBatch() deal with UPDATE_AFTER ?
#2
liyubin117
closed
2 years ago
1
通过writeLocal判断创建是batch/shard的逻辑是否反了?
#1
Aireed
closed
2 years ago
1
Previous