flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 周虓岗 <zhou16...@163.com>
Subject flink table api监控及并行度相关问题
Date Tue, 24 Sep 2019 12:30:53 GMT
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算子怎么设置并行度
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message