?????? flink 1.10webui??????print????

Tue, 26 May 2020 16:47:05 -0700 

????????????checkpoint????????????,??????,idea,webui????????????????,????????????????,????????????????webui??????




------------------ ???????? ------------------
??????:&nbsp;"tison"<[email protected]&gt;;
????????:&nbsp;2020??5??27??(??????) ????7:42
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.10webui??????print????



???????????????????????? Web UI ??????Flink ?????????????? Web UI 
???????????????????????????? Catch ????????????????????

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

?????????????????????????????????? taskmanager.out ????????????

Best,
tison.


smq <[email protected]&gt; ??2020??5??27?????? ????7:34??????

&gt; FlinkKafkaConsumer011<String&amp;gt; consumer = new
&gt; FlinkKafkaConsumer011<&amp;gt;(topic, new SimpleStringSchema(), 
properties);
&gt;&nbsp;&nbsp;&nbsp;&nbsp; consumer.setStartFromLatest();
&gt;&nbsp;&nbsp;&nbsp;&nbsp; DataStreamSource<String&amp;gt; stream = 
env.addSource(consumer);
&gt;&nbsp;&nbsp;&nbsp;&nbsp; SingleOutputStreamOperator<Tuple2<String, 
Integer&amp;gt;&amp;gt; sum =
&gt; stream.map(
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
new MapFunction<String, Tuple2<String, Integer&amp;gt;&amp;gt;() {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 int num = 0;
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 @Override
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 public Tuple2<String, Integer&amp;gt; map(String s) {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 num++;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 if (num % 10 == 0) {
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 System.out.println("????????,????????");
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 throw new RuntimeException("????????????????????");
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 } else {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 return new Tuple2(s, 1);
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 }
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 }
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
}).keyBy(0)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
.sum(1);
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp; sum.print();
&gt;&nbsp;&nbsp;&nbsp;&nbsp; try {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; env.execute();
&gt;&nbsp;&nbsp;&nbsp;&nbsp; } catch (Exception e) {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace();
&gt;&nbsp;&nbsp;&nbsp;&nbsp; }
&gt; }
&gt; ??????????????
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"Benchao Li"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??5??26??(??????) ????11:29
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: flink 1.10webui??????print????
&gt;
&gt;
&gt;
&gt; ??????????????????????????print??????
&gt;
&gt; smq <[email protected]&amp;gt; ??2020??5??26?????? ????11:20??????
&gt;
&gt; &amp;gt; 
??????????????????????webui????????????????????????????????client??
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ---????????---
&gt; &amp;gt; ??????: &amp;amp;quot;Lijie 
Wang&amp;amp;quot;<[email protected]&amp;amp;gt;
&gt; &amp;gt; ????????: 2020??5??26??(????) ????10:14
&gt; &amp;gt; ??????: &amp;amp;quot;[email protected]&amp;amp;quot;<
&gt; [email protected]&amp;amp;gt;;
&gt; &amp;gt; ????: ??????flink 1.10webui??????print????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ?????????????????????????????????????????????????? 
taskmanager.out ???????????? ?????????????????????? print
&gt; &amp;gt; ???????????????? TM ?????????????????? client ????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ??2020??05??26?? 21:39??smq<[email protected]&amp;amp;gt; ??????
&gt; &amp;gt; Hi
&gt; &amp;gt; 
??????????????????????????webui??stdout??????????????????????????????????????????????????????????1.10??????
&gt; &amp;gt; ????????????????????????????????????
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt; Best,
&gt; Benchao Li

回复