@Override
    public String getUpdateStatement(String tableName, String[] fieldNames, String[] conditionFields) {
        throw new RuntimeException("Clickhouse does not support update sql, please remove primary key or use append mode");
    }
Date: 2020/1/15
Company: www.dtstack.com
@author maqi
clickhouse/clickhouse-sink/src/main/java/com/dtstack/flink/sql/sink/clickhouse/ClickhouseDialect.java