开发者社区> 问答> 正文

flink sql 写hdfs问题,如何解决?

flink.version=1.12.0 Create table t1( a varchar )with ( connector=kafka format=json )

Create table t2( a varchar )with ( connector=filesystem format=csv )

SQL: Insert into t2 select a from t1

发送: {"a":[{"a1":1,"a2":2}]} Hdfs的结果为:"[{""a1"":1,""a2"":2}]” 问题:为什么一个双引号变成了2个双引号? 发送到其它目标是正常的,发送到hdfs就会变成这样,这个要怎么解决?*来自志愿者整理的flink

展开
收起
雪哥哥 2021-12-05 12:05:36 1031 0
1 条回答
写回答
取消 提交回答
  • hi 你需要添加下面两个参数: 'csv.line-delimiter'='', 'csv.disable-quote-character'='true'*来自志愿者整理的flink

    2021-12-05 17:30:15
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server在电子商务中的应用与实践 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载