??????????????blinkplanner??????????????????????????????proctime??????????????????????TimeStamp????????LocalDateTime??


org.apache.flink.table.dataformat.DataFormatConverters??TimestampConverter ??
toInternalImpl??????????TimeStamp??????????????????????????????long????????????????????????????????toInternalImpl??????????long??????????????????????
------------------ ???????? ------------------
??????:&nbsp;"Kurt Young"<[email protected]&gt;;
????????:&nbsp;2020??4??1??(??????) ????9:22
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;?????????????? 1.11 ???????? blink planner ?????????? planner



????????

??????????????Blink planner ?? Flink 1.9 ?????????????????????? Table API ?? 
SQL ??????????
?????????????????? 1.10 ?????????????? SQL CLI ?????? 
planner????????????????????????????
?????????????????????????????????????????????????????????????? flink planner 
????????????
?????????????? SQL ????????????????????????????????????DDL?????????????????? 
1.11 ????
?????? TableSource ?? TableSink ?????????????????? Binlog ??????????????

???????????????????????????? 1.11 ???????????? blink planner ???????????? 
planner??????????
???????????????????????????????????????????????????????????????????????????? 
blink planner
???????????????????????????????? flink planner 
?????????????????????????????????? blink planner
?????????? bug ?????? planner ?????????????? 1.11 
??????????????????????????????????????
??????????????????????????????????????????????

??????????????????????????????????

Best,
Kurt

回复