flink-connector-clickhouse
                                
                                 flink-connector-clickhouse copied to clipboard
                                
                                    flink-connector-clickhouse copied to clipboard
                            
                            
                            
                        I cannot use OPTION 'properties.*'.
https://github.com/itinycheng/flink-connector-clickhouse/blob/a71a0ed2d55f63f903cf7d3bbe0c3ecaf0a9ba92/flink-connector-clickhouse/src/main/java/org/apache/flink/connector/clickhouse/internal/AbstractClickHouseOutputFormat.java#L192
I cannot use OPTION 'properties.*', it does not work, it always empty in ClickHouseConnectionProvider class.
If I changed code like this, it works for me -
connectionProvider = new ClickHouseConnectionProvider(options); to
connectionProvider = new ClickHouseConnectionProvider(options, connectionProperties);
Hi @YahorBurakevich
Can you describe the scenario where you have to pass 'properties.*' to this temporary ClickHouse connection?
Hi, @itinycheng I need to use ssl mode for connect to Clickhouse. I passed properties.ssl = true
Hi, @itinycheng I need to use ssl mode for connect to Clickhouse. I passed properties.ssl = true
@YahorBurakevich
Ok, got it.
Use new ClickHouseConnectionProvider(options, connectionProperties); seems more reasonable here.
I'll find time to fix it.
@itinycheng I test properties.ssl = false,it seems not work on flink sql