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

Tue, 26 May 2020 16:35:11 -0700 

FlinkKafkaConsumer011<String&gt; consumer = new 
FlinkKafkaConsumer011<&gt;(topic, new SimpleStringSchema(), properties);
    consumer.setStartFromLatest();
    DataStreamSource<String&gt; stream = env.addSource(consumer);
    SingleOutputStreamOperator<Tuple2<String, Integer&gt;&gt; sum = stream.map(
            new MapFunction<String, Tuple2<String, Integer&gt;&gt;() {
                int num = 0;

                @Override
                public Tuple2<String, Integer&gt; map(String s) {
                    num++;
                    if (num % 10 == 0) {
                       
                        System.out.println("????????,????????");
                        throw new RuntimeException("????????????????????");
                    } else {
                        return new Tuple2(s, 1);
                    }
                }
            }).keyBy(0)
            .sum(1);

    sum.print();
    try {
        env.execute();
    } catch (Exception e) {
        e.printStackTrace();
    }
}
??????????????


------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"Benchao Li"<[email protected]&gt;;
????????:&nbsp;2020??5??26??(??????) ????11:29
??????:&nbsp;"user-zh"<[email protected]&gt;;

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



??????????????????????????print??????

smq <[email protected]&gt; ??2020??5??26?????? ????11:20??????

&gt; ??????????????????????webui????????????????????????????????client??
&gt;
&gt;
&gt; ---????????---
&gt; ??????: &amp;quot;Lijie Wang&amp;quot;<[email protected]&amp;gt;
&gt; ????????: 2020??5??26??(????) ????10:14
&gt; ??????: 
&amp;quot;[email protected]&amp;quot;<[email protected]&amp;gt;;
&gt; ????: ??????flink 1.10webui??????print????
&gt;
&gt;
&gt; ?????????????????????????????????????????????????? taskmanager.out 
???????????? ?????????????????????? print
&gt; ???????????????? TM ?????????????????? client ????????????
&gt;
&gt;
&gt;
&gt;
&gt; ??2020??05??26?? 21:39??smq<[email protected]&amp;gt; ??????
&gt; Hi
&gt; 
??????????????????????????webui??stdout??????????????????????????????????????????????????????????1.10??????
&gt; ????????????????????????????????????



-- 

Best,
Benchao Li

回复