[
https://issues.apache.org/jira/browse/BAHIR-234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606785#comment-17606785
]
Kanthi Subramanian commented on BAHIR-234:
------------------------------------------
Would love to work on this and use the existing PR as a reference.
> add ClickHouse Connector for Flink
> ----------------------------------
>
> Key: BAHIR-234
> URL: https://issues.apache.org/jira/browse/BAHIR-234
> Project: Bahir
> Issue Type: New Feature
> Components: Flink Streaming Connectors
> Affects Versions: Flink-1.0
> Reporter: Fangliang Liu
> Priority: Major
>
> [ClickHouse website : https://clickhouse.tech/|https://clickhouse.tech/]
> ClickHouse is a column-oriented database management system (DBMS) for online
> analytical processing of queries (OLAP)
> we can add flink connector for ClickHouse，including Streaming Implement &
> Table API & SQL.
> CREATE TABLE test (
> d BIGINT,
> s VARCHAR(10)
> ) WITH (
> 'connector.properties.bootstrap.servers'='localhost:9092',
> 'connector.properties.group.id'='testclickhouse',
> 'connector.properties.zookeeper.connect'='localhost:2181',
> 'connector.startup-mode'='latest-offset',
> 'connector.topic'='flinksql',
> 'connector.type'='kafka',
> 'connector.version'='universal',
> 'format.type'='json',
> 'format.derive-schema' = 'true',
> 'update-mode'='append'
> );
> CREATE TABLE test2 (
> usrname STRING,
> size BIGINT
> ) WITH (
> 'connector.type'='clickhouse',
> 'connector.version'='1',
> 'connector.property-version'='1',
> 'connector.address'='localhost:8123',
> 'connector.database'='test',
> 'connector.table'='insert_test',
> 'connector.username'='admin',
> 'connector.password'='admin',
> 'connector.commit.batch.size'='1',
> 'connector.commit.padding'='2000',
> 'connector.commit.retry.attempts'='3',
> 'connector.commit.retry.interval'='3000',
> 'connector.commit.ignore.error'='FALSE'
> );
> insert into test2 select s as usrname ,d as size from test ;
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
