??????????Kyuubi????FlinkSQL??????????????k8s????????????????????????????(Application
 mode)??????????(Session 
mode)????Application??????????jar??????jobgraph??SQL??????????


CREATE TABLE T (
id INT
 ) WITH (
'connector.type' = 'filesystem',
'connector.path' = 'file:///tmp/tmp.csv',
'format.type' = 'csv',
'format.derive-schema' = 'true'
);



insert into T values(1);




insert????????????????Application????????????????????????????????????SQL????????????,
 
??????????????????????????(catalog)??????????????????????????SQL????????????????????????SQL????????????????????????????
 
????????????table??Executor????????????????jobgraph????????jobgraph??????????????????????????????SQL????????k8s??????????per
 job??????????????????


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

回复