You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 周虓岗 <zh...@163.com> on 2019/09/24 12:30:53 UTC

flink table api监控及并行度相关问题

publicclassMyMapperextendsRichMapFunction<Long,Long>{privatetransientMetermeter;@Overridepublicvoidopen(Configurationconfig){this.meter=getRuntimeContext().getMetricGroup().meter("myMeter",newMyMeter());}@OverridepublicLongmap(Longvalue)throwsException{this.meter.markEvent();returnvalue;}}

默认的监控从open中获取meter，当使用table时没有这些api，如何才能监控


以及，table的sink算子怎么设置并行度