flink-clickhouse-sink

flink-clickhouse-sink copied to clipboard

I want to sink data via insert query like below. INSERT INTO jordy(user_id, message) SELECT 10, saleDate AS aa FROM sale_date LIMIT 1; But insert query format like this INSERT...

retrogemHK

In the incremental synchronization phase, MySQL data is synchronized through Flinkcdc and then inserted into the clickhouse. During the synchronization process, restarting MySQL found that some logs were lost in...

yuhailove11

WriterTask thread will be closed one by one.

6

Thanks for your work! I encounter a problem！After the program runs for a while, I found that ```ru.ivi.opensource.flinkclickhousesink.applied.ClickHouseWriter$WriterTask``` will be closed one by one; I checked the log: There are...

ChaoHsupin

Hi , Dose the flink-clickhouse-sink latest version 1.4 support flink 1.14.6?

Valentine1506

Summary: This pull request addresses two key updates: 1. Library Dependency Upgrade: Updated the library dependencies in the ClickHouse sink module to ensure compatibility with Apache Flink 1.20 2. Maven...

darthgelum