首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >如何在Flink中增加SinkFunction的numRecordsOutPut指标?

如何在Flink中增加SinkFunction的numRecordsOutPut指标?
EN

Stack Overflow用户
提问于 2019-02-28 23:10:21
回答 1查看 307关注 0票数 0

我正在使用flink消费kafka并写入redis。

下面是我对redis的接收器函数:

代码语言:javascript
复制
            .addSink(new RichSinkFunction<MobilePageEvent>() {

                @Override
                public void invoke(MobilePageEvent event, Context context) {

                    JEDIS_CLUSTER.zadd(..);
                }
            })
            .name("redis sink");

虽然我可以从redis命令行中获取数据,但指标显示汇函数的输出为零:

如何增加此指标?

EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/54928734

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档