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