flink1.10,flink-sql,pyflink创建hdfs的sink表后,不能append,一直报目录已存在的错误

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink1.10,flink-sql,pyflink创建hdfs的sink表后,不能append,一直报目录已存在的错误

瞿叶奇
各位,您们好,
我遇到了一个问题 ,创建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')
我想问一下,我需要改动,才能保证新数据追加到文件呢?