开发者社区> 问答> 正文

pyflink 如何指定csv分隔符为“||”

format='csv'想要指定分割符为"||",设置为:

报错:

Caused by: org.apache.flink.table.api.ValidationException: Option 'csv.field-delimiter' must be a string with single character, but was: ||

请问该如何指定分隔符为“||” ?*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 15:02:33 566 0
1 条回答
写回答
取消 提交回答
  • 嗯,需要打成Jar包,才可以在PyFlink里用: 

    1)需要创建一个fat jar,把依赖都shade到jar里面。现在默认的不是fat jar,需要修改一下pom文件,可以参考Kafka里的做法 [1]。 

    2)关于如何使用,可用的属性有这些 [2] 

    [1] https://github.com/apache/flink/blob/master/flink-connectors/flink-sql-connector-kafka/pom.xml#L46 

    [2] https://github.com/apache/bahir-flink/blob/f0b3e1e04930b79b277cfc7ebe3552db246578e9/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java*来自志愿者整理的FLINK邮件归档

    2021-12-02 15:55:09
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
File Format Benchmark - Avro, JSON, ORC, & Parquet 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载