zdl11111 commented on issue #9940:
URL: https://github.com/apache/hudi/issues/9940#issuecomment-1788576963
> It's okay if there is no streaming read.
Thanks for your help, it works, but there is a wired example:
Flink SQL> select * from source;
| op | id | ts | name |
description | weight |
+----+-------------+----------------------+--------------------------------+--------------------------------+--------------------------------+
| +I | 111 | 13000 | scooter |
Big 2-wheel scooter | 5.179999828338623 |
| -U | 111 | 13000 | scooter |
Big 2-wheel scooter | 5.179999828338623 |
| +U | 111 | 13000 | scooter1 |
Big 2-wheel scooter | 5.170000076293945 |
This is the source, insert to a hudi table:**insert into test103 select *
from source;**Then query data
Flink SQL> select * from test103;
| op | id | ts | name |
description | weight |
+----+-------------+----------------------+--------------------------------+--------------------------------+--------------------------------+
Received a total of 0 row
Here is the create sql for table test103:
CREATE TABLE test103(
id INT NOT NULL PRIMARY KEY NOT ENFORCED,
ts BIGINT,
name STRING,
description STRING,
weight DOUBLE
) WITH (
'connector' = 'hudi',
'table.type' = 'MERGE_ON_READ',
'path' = 'hdfs://hudi/flink/origin4',
'precombine.field' = 'ts'
);
do you have any ideas?
--
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]
