doris-flink-connector
doris-flink-connector copied to clipboard
[fix] Fix the bug that the `DorisTypeMapper` datetime type will lose precision when converted to flink type
Proposed changes
Issue Number: close #378
Problem Summary:
#378
Checklist(Required)
- Does it affect the original behavior: (Yes/No/I Don't know)
- Has unit tests been added: (Yes/No/No Need)
- Has document been added or modified: (Yes/No/No Need)
- Does it need to update dependencies: (Yes/No)
- Are there any changes that cannot be rolled back: (Yes/No)
Further comments
If this is a relatively large or complex change, kick off the discussion at [email protected] by explaining why you chose the solution you did and what alternatives you considered, etc...
Did you create the table through catalog?
Did you create the table through catalog?
no, it was not created through flink doris catalog
How was that triggered? In theory, the catalog will reach this point
How was that triggered? In theory, the catalog will reach this point
Then the doris table is created through the doris command and then written through flink
As shown in the figure, the stime field is at the millisecond level. I write it through flink.
USE CATALOG doris;
insert into doris.db,table xxx
The DorisCatalog#getTable
method will return the mapping of the doris table to the flink table. The precision is not considered when processing the datetime type.