mincwang edited a comment on issue #6550:
URL:
https://github.com/apache/incubator-doris/issues/6550#issuecomment-918741871
@JNSimba thanks for your reply. here is my code, and some errors.
doris ddl：
```sql
CREATE TABLE `product` (
`id` int(11) NULL COMMENT "",
...
`gmt_modified` datetime NULL COMMENT "",
`gmt_create` datetime NULL COMMENT ""
) ENGINE=OLAP
DUPLICATE KEY(`id`, `id_hash`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`id`) BUCKETS 10
PROPERTIES (
"replication_num" = "3",
"in_memory" = "false",
"storage_format" = "V2"
);
```
flink sql doris-sink ddl：
```sql
CREATE TABLE product (
id INT,
...
gmt_modified TIMESTAMP(6),
gmt_create TIMESTAMP(6) )
WITH (
'connector' = 'doris',
'fenodes' = 'n3:8031',
'table.identifier' = 'dev.product',
'username' = 'root',
'sink.batch.size' = '100',
'sink.properties.column_separator' = '\x01',
'sink.properties.line_delimiter' = '\x02',
'sink.batch.interval' = '2s' ,
'password' = 'doris'
);
```
```sql
# flink insert sql
insert into product
select * from product_cdc_table ;
```
When we write data to dorsi by flink streaming, have following error occurs.
```bash
Reason: actual column number is less than schema column number. actual
number: 1 sep: , schema number: 19; . src line:
[689\x018a7c7089faaf00c850b90154e74fb821\x01101787\x0111\x010\x010\x010\x01\x01\x01QARFEE
Headphone/Earphone Audio&Charge Adapter Splitter Compatible Only for iPhone X
8/8 Plus 7/7 Plus,iPad,iPod,for iOS 10 11 12 Or Later\x01QARFEE
Headphone/Earphone Audio&Charge Adapter Splitter Compatible For iPhone X 8/8
Plus 7/7 Plus,iPad,iPod,For IOS 10 11 12 Or Later,Not for iphone Xs,iphone Xs
Max,Iphone Xr.\x01B07JZ5NQNR\x01QAC21\x010.000\x010\x012018-10-29 01:05:29
PDT\x01\x012019-10-15T04:34:14\x012019-04-03T22:37:41\x02
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
