pyflink ????????csv??????????||??

Tue, 29 Dec 2020 20:04:39 -0800 

format='csv'????????????????"||"??????????



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




????????????????????????||?? ?





------------------ ???????? ------------------
??????:                                                                         
                                               "Dian Fu"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??12??17??(??????) ????3:12
??????:&nbsp;"user-zh"<[email protected]&gt;;
????:&nbsp;"??????"<[email protected]&gt;;
????:&nbsp;Re: ??????pyflink??sink????????redis connector?



????????????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



?? 2020??12??17????????11:55??magichuang <[email protected]&gt; ??????

hi,

?????????? &nbsp;&nbsp; ???? 
&nbsp;https://github.com/apache/bahir-flink/tree/master/flink-connector-redis 
??????????jar????????????pyflink????

??java??????????????????????????????java??scala??????????







Best??

MagicHuang




------------------ ???????? ------------------
?? ?? ????"Dian Fu" <[email protected]&gt;
??????????2020-12-17 10:16:13
?? ?? ????user-zh <[email protected]&gt;,[email protected]
?? ????
?? ????Re: ??????pyflink??sink????????redis connector?

????Xingbo??????????????????????????Table &amp; 
SQL??????connector??????????PyFlink????

redis??connector??????????Flink??????????????????????????????????????????https://github.com/apache/bahir-flink/tree/master/flink-connector-redis

??????????PyFlink??????connector????????????????https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/python_table_api_connectors.html

?? 2020??12??17????????9:52??Xingbo Huang ??????

Hi,

??????????flink??????????redis 
connector??????????[1]??????????????????????????????????????redis
connector????????????????connector????????????????[2]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sourceSinks.html

Best,
Xingbo


?????? ??2020??12??17?????? ????9:33??????

??????


??????????????????pyflink??????????????????????????????????????1.12.0??????pyflink??sink????????redis
connector???????
 &nbsp;&nbsp;&nbsp;&nbsp; ????????????????????????

回复