lingya

support each flink job use a custom user name

new ck sink

add clickhouse-sink support

1

create sink table flink2ck( key varchar, message varchar, event_time date ) with( type = 'ideal.sylph.plugins.clickhouse.ClickHouseSink', userName = 'default', password ='default', bulkSize = 20000 -- 默认20000 url = 'jdbc:clickhouse://localhost:9000', query =...

Integration with Flink

5

### Environment - OS version: - JDK version: - ClickHouse Server version: - ClickHouse Native JDBC version: - (Optional) Spark version: N/A - (Optional) Other components' version: N/A ### Error...

support flink V1.11.1

1

can upgrade flink to v1.11.1?

can upgrade flink v1.11.1?