??????????????
???????????????? ??????hdfs??sink??????????????????????????????????

??????????
CREATE TABLE csvTableSink ( id BIGINT,name STRING) WITH ('connector.path'= 
'hdfs://hacluster/flink/qyq_qyq13','connector.type'='filesystem','format.type'='csv','update-mode'
 = 'append')
????????????????????????????????????????????????????

Reply via email to