?????????????? dlink ?????????? FlinkSQL??
https://github.com/DataLinkDC/dlink
------------------ ???????? ------------------
??????:
"user-zh"
<wang4lun...@gmail.com>;
????????: 2022??4??25??(??????) ????4:27
??????: "user-zh"<user-zh@flink.apache.org>;
????: Re: FlinkSQL ????k8s??????????
SQL Client??Application????????????????????????????????
https://issues.apache.org/jira/browse/FLINK-26541
?????? <1365976...@qq.com.invalid> ??2022??4??24?????? 14:45??????
>
??????????Kyuubi????FlinkSQL??????????????k8s????????????????????????????(Application
> mode)??????????(Session
mode)????Application??????????jar??????jobgraph??SQL??????????
>
>
> CREATE TABLE T (
> id INT
> &nbsp;) 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??????????????????
>
>
>
????????????????????????????????????????????????????????????????????????????????????????????
