hi:
????????sink
??????table????datastream????????????????????????????sink??????????dataStream.addSink(sink)(??????????????????????????????????),
??????????????????????????????????????????????????????????????????
------------------ ???????? ------------------
??????:
"user-zh"
<[email protected]>;
????????: 2020??8??7??(??????) ????4:35
??????: "user-zh"<[email protected]>;
????: Re: Re: Table Api????sql????????sink??????
hi, ????????????????????????????????????????sink??????????????
????????sink????????????????????????
https://www.mail-archive.com/[email protected]/msg40251.html
wldd <[email protected]> ??2020??8??7?????? ????3:41??????
> hi??
>
??????????????flink-conf.yaml??????????????????????????????????????sink????????
>
>
>
>
>
>
>
>
>
>
>
>
>
> --
>
> Best??
> wldd
>
>
>
>
>
> ?? 2020-08-07 15:26:34??"Shengkai Fang" <[email protected]> ??????
> >hi
> >?????? ??????????????????????
> >
> >tEnv.getConfig().addConfiguration(
> >new Configuration()
> >.set(CoreOptions.DEFAULT_PARALLELISM, 128)
> >);
> >
> >??????????
> https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html
> >
> >
> >wldd <[email protected]> ??2020??8??7?????? ????3:16??????
> >
> >> hi??all??
> >>
??????????TableEnviroment??????sql??????????????sink????????
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >> --
> >>
> >> Best??
> >> wldd
>