flink sql写filesystem问题

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

flink sql写filesystem问题

酷酷的浑蛋
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就会变成这样,这个要怎么解决?