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
349 stars 149 forks source link

不支持指定sink 算子 #37

Closed qiunan1 closed 2 years ago

qiunan1 commented 2 years ago

image image

qiunan1 commented 2 years ago

org.apache.flink.connector.clickhouse.ClickHouseDynamicTableSink#getSinkRuntimeProvider 我们可以将算子的并行度传到该方法的参数上

itinycheng commented 2 years ago

org.apache.flink.connector.clickhouse.ClickHouseDynamicTableSink#getSinkRuntimeProvider 我们可以将算子的并行度传到该方法的参数上

Yes, nice idea.

itinycheng commented 2 years ago

@v-qiunan Already added. https://github.com/itinycheng/flink-connector-clickhouse/commit/fb0a878cb885818897085f074cb3bc2932434157