hi:
  ????????sink 
??????table????datastream????????????????????????????sink??????????dataStream.addSink(sink)(??????????????????????????????????),
  ?????????????????????????????????????????????????????????????????? 




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<fskm...@gmail.com&gt;;
????????:&nbsp;2020??8??7??(??????) ????4:35
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: Re: Table Api????sql????????sink??????



hi, ????????????????????????????????????????sink??????????????
&nbsp;????????sink????????????????????????
https://www.mail-archive.com/dev@flink.apache.org/msg40251.html
wldd <wldd1...@163.com&gt; ??2020??8??7?????? ????3:41??????

&gt; hi??
&gt;&nbsp;&nbsp; 
??????????????flink-conf.yaml??????????????????????????????????????sink????????
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt; Best??
&gt; wldd
&gt;
&gt;
&gt;
&gt;
&gt;
&gt; ?? 2020-08-07 15:26:34??"Shengkai Fang" <fskm...@gmail.com&gt; ??????
&gt; &gt;hi
&gt; &gt;?????? ??????????????????????
&gt; &gt;
&gt; &gt;tEnv.getConfig().addConfiguration(
&gt; &gt;new Configuration()
&gt; &gt;.set(CoreOptions.DEFAULT_PARALLELISM, 128)
&gt; &gt;);
&gt; &gt;
&gt; &gt;??????????
&gt; https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html
&gt; &gt;
&gt; &gt;
&gt; &gt;wldd <wldd1...@163.com&gt; ??2020??8??7?????? ????3:16??????
&gt; &gt;
&gt; &gt;&gt; hi??all??
&gt; &gt;&gt;&nbsp;&nbsp; 
??????????TableEnviroment??????sql??????????????sink????????
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt;
&gt; &gt;&gt; --
&gt; &gt;&gt;
&gt; &gt;&gt; Best??
&gt; &gt;&gt; wldd
&gt;

回复