新定义了 这个 metrics , 又从 0 开始计数了。
>
> 谢谢,
> 王磊
>
>
> wangl...@geekplus.com.cn
>
>
> Sender: kcz
> Send Time: 2020-07-03 09:13
> Receiver: wanglei2
> Subject: 回复:在一个 flink operator 中怎样根据消息内容动态生成多个监控指标?
> 按照你的描述 你就是少了tablename,那么你解析log 得到了tablename又做metric就好了吧
>
og.info("### counter: " + meter.toString() + "\t" + meter.getCount());
如上面代码所示,在 invoke 方法中解析得到 tableName, 以 tableName 名字作为 metrics.
但这样写每一消息下来了后相当于重新定义了 这个 metrics , 又从 0 开始计数了。
谢谢,
王磊
wangl...@geekplus.com.cn
Sender: kcz
Send Time: 2020-07-03 09:13
Receiver: wanglei2
Subject: 回复:在一个 fl
12
收件人:user-zh
主 题:回复:在一个 flink operator 中怎样根据消息内容动态生成多个监控指标?
你把tablename传到下面metric里不就行了吗
| |
JasonLee
|
|
邮箱:17610775...@163.com
|
Signature is customized by Netease Mail Master
在2020年07月02日 16:39,wangl...@geekplus.com.cn 写道:
全都是同一种类型的 metrics.
比如消息中是 mysql binlog 解析结果,我想要根据消息内容拿到 tableN
...@geekplus.com.cn
发件人: JasonLee
发送时间: 2020-07-02 16:16
收件人: user-zh
主题: 回复:在一个 flink operator 中怎样根据消息内容动态生成多个监控指标?
是要生成不同类型的metric吗 比如counter meter ?
| |
JasonLee
|
|
邮箱:17610775...@163.com
|
Signature is customized by Netease Mail Master
在2020年07月02日 15:34,wangl...@geekplus.com.cn 写道:
官网上的例
全都是同一种类型的 metrics.
比如消息中是 mysql binlog 解析结果,我想要根据消息内容拿到 tableName, 按 tableName 生成不同名称的 metrics(但都是
meter 类型)
谢谢,
王磊
wangl...@geekplus.com.cn
发件人: JasonLee
发送时间: 2020-07-02 16:16
收件人: user-zh
主题: 回复:在一个 flink operator 中怎样根据消息内容动态生成多个监控指标?
是要生成不同类型的metric吗 比如counter meter
是要生成不同类型的metric吗 比如counter meter ?
| |
JasonLee
|
|
邮箱:17610775...@163.com
|
Signature is customized by Netease Mail Master
在2020年07月02日 15:34,wangl...@geekplus.com.cn 写道:
官网上的例子:
public class MyMapper extends RichMapFunction {
private transient Counter counter;
@Override
public void open(