format='csv'想要指定分割符为"||",设置为:
报错:
Caused by: org.apache.flink.table.api.ValidationException: Option 'csv.field-delimiter' must be a string with single character, but was: ||
请问该如何指定分隔符为“||” ?*来自志愿者整理的flink邮件归档
嗯,需要打成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邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。