[
https://issues.apache.org/jira/browse/FLINK-22174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-22174:
------------------------------
Attachment: image-2021-04-09-16-09-28-903.png
> `csv.quote-character` does not work for csv format when sink
> ----------------------------------------------------------------
>
> Key: FLINK-22174
> URL: https://issues.apache.org/jira/browse/FLINK-22174
> Project: Flink
> Issue Type: Bug
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Reporter: hehuiyuan
> Priority: Minor
> Attachments: image-2021-04-09-16-09-28-903.png,
> image-2021-04-09-16-09-48-119.png
>
>
> {code:java}
> CREATE TABLE kafkaTableSource (
> name string,
> age int,
> sex string,
> address string
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'hehuiyuan1',
> 'scan.startup.mode' = 'latest-offset',
> 'properties.bootstrap.servers' = 'localhost:9092',
> 'properties.client.id' = 'test-consumer-group',
> 'properties.group.id' = 'test-consumer-group',
> 'format' = 'csv',
> 'csv.quote-character' = '*'
> );
> CREATE TABLE kafkaTableSink (
> name string,
> age int,
> sex string,
> address string
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'hehuiyuan2',
> 'properties.bootstrap.servers' = 'localhost:9092',
> 'format' = 'csv',
> 'csv.quote-character' = '#'
> );
> insert into kafkaTableSink select * from kafkaTableSource;
> {code}
>
> Test 1 :
> Generate data for topic `hehuiyuan1`
> {code:java}
> >hehuiyuan,22,man,hengshui
> >*hehuiyuan*,*22*,*man*,*hengshui*
> >#hehuiyuan#,22,#man#,#hengshui#
> >hehuiyuan,22,#man#,#hengshui#
> >"hehuiyuan",22,#man#,#hengshui#
> {code}
>
> Result data for topic `hehuiyuan2`
> {code:java}
> >hehuiyuan,22,man,hengshui
> >hehuiyuan,22,man,hengshui
> >###hehuiyuan###,22,###man###,###hengshui###
> >hehuiyuan,22,###man###,###hengshui###
> >#"hehuiyuan"#,22,###man###,###hengshui###
> {code}
> I think the result shoule be ` #hehuiyuan#,22,#man#,#hengshui# ` for the
> first and second data.
>
> Test 2:
> Add Timestamp field:
> {code:java}
> CREATE TABLE kafkaTableSource (
> name string,
> age int,
> sex string,
> address string,
> dt timestamp(3)
> ) WITH (
> {code}
> Generate data for topic `hehuiyuan1`
> {code:java}
> >hehuiyuan,22,man,hengshui,2020-12-12 12:12:12
> >hehuiyuan,22,man,hengshui,2020-12-16 10:00:00{code}
> Result data for topic `hehuiyuan2`
> {code:java}
> >hehuiyuan,22,man,hengshui,#2020-12-12 12:12:12#
> >hehuiyuan,22,man,hengshui,#2020-12-16 10:00:00#
> {code}
>
>
>
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
