flink-clickhouse-sink

flink-clickhouse-sink copied to clipboard

Add S3 upload feature; if enabled, upload the failed records to s3

3

Testing is bit flaky. Need suggestions to add tests. Failed records can be uploaded to S3 which makes this sink completely stateless.

rajatkooapp

Insert fails if insert field carries ' character

4

Insert fails if insert field carries ' character and throw exception "cannot parse expression of type String here"

luffy0223

About insert record through JSONEachRow format

1

I think the json format record is easier then csv format.What should I do if I want to modify the format type?

PayneZx

Does this support newest version 1.15?

3

Does this support newest version 1.15?

felixruan

mchernyakov

Added a JAR file on Flink SQL but can't create a Clickhouse sink table properly

1

Hi, I am trying to create a Clickhouse (CH) sink table using Flink SQL. I am new at using Flink SQL and I was trying to create a sink table...

nsia-henry

The interface for converter to ClickHouse format

2

@aleksanchezz @ashulenko Probably, for more obvious using this sink we should add the cpecific interface, something like this: ```java public interface ClickHouseSinkConverter { String convert(T record); } ``` And we...

mchernyakov

Hi folks @ashulenko @aleksanchezz @MariaNosareva, how about migrating this project from Maven to Gradle? I found that with Gradle it is much easier to build, sign and deploy in maven...

mchernyakov

when there is no data to sink, the while endless loop will take too much cpu. Maybe we can improve it with Scheduled task and counting task。

lpn666

Bumps [ch.qos.logback:logback-classic](https://github.com/qos-ch/logback) from 1.2.3 to 1.2.13. Commits 2648b9e prepare release 1.2.13 bb09515 fix CVE-2023-6378 4573294 start work on 1.2.13-SNAPSHOT a388193 Merge branch 'branch_1.2.x' of github.com:qos-ch/logback into branch_1.2.x de44dc4 prepare release...

dependabot[bot]