flink内存参数

2020-01-16 文章
| | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制

回复:jobgraph 生成

2020-01-07 文章
Very sorry for the wrong operation. I copied the wrong email address by the phone. Thank you for your reply. | | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制 在2020年01月08日 11:08,tison 写道: Hi Zhang, I just notice that it is sent to user list. Please send to user-zh list(in cc) next time

Re:回复: 回复:如何获取算子处理一条数据记录的时间

2020-01-06 文章
好的,谢谢 在 2020-01-06 20:04:09,"戴嘉诚" 写道: >你可以在算子中计算,然后上传到自定义的Flink Metrics中,这样就能看到平均一个算子的时间了. > >发件人: 张江 >发送时间: 2020年1月2日 19:18 >收件人: user-zh >抄送: user-zh >主题: 回复:如何获取算子处理一条数据记录的时间 > >我其实是想知道算子的数据处理能力,得到一个算子每秒钟最多能处理多少条数据。比如说map算子,我需要知道它一秒钟最多能转换多少数据,之后根据source端的数

Re:Re: 回复:使用influxdb作为flink metrics reporter

2020-01-06 文章
好的,多谢 在 2020-01-06 01:38:22,"Yun Tang" 写道: >Hi 张江 > >这个invalid boolean >一般是tag和field中间穿插空格有关,导致influxDB识别匹配的时候出了问题,你的原始报错信息是什么,不要隐去你的operator >name和task name,另外task_id= 后面的那个空格是你粘贴时候的错误还是原先就是这样。 > >最后,这些只会是warning,不会导致你的其他m

回复:使用influxdb作为flink metrics reporter

2020-01-04 文章
你好, 我看我这里报错的问题是invalid boolean,并不是NaN/infinity value造成的,不知道是什么原因? 而且我用的flink是1.9.1版本,influxdb是1.7.9版本。 祝好, | | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制 在2020年01月04日 00:56,Yun Tang 写道: Hi 张江 * Retention policy 需要现在InfluxDB端创建,InfluxDBReporter不会自行创建不存在的 retention policy

单个算子处理一条数据的真实处理时间

2020-01-03 文章
大家好, 之前问过类似的问题,可能表达不太清楚。向各位大佬再请教一下。 有人知道怎么获取以下的flink metrics么: 这个是flink forward asia 2019会议上马庆祥老师讲的flink动态资源调整里的内容。但我自己在flink官网上没有看到metrics有这个指标信息。 谢谢。 祝好,

使用influxdb作为flink metrics reporter

2020-01-03 文章
大家好, 我按照官网所介绍的flink metrics reporter设置,选用了influxdb,进行了如下设置:

回复:如何获取算子处理一条数据记录的时间

2020-01-01 文章
有人知道么 | | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制 在2019年12月31日 17:14,张江 写道: Hi, 我是刚学习flink的菜鸟,现在想对一个算子,获取其处理一条数据记录的时间。请问这个应该怎么做? 谢谢 | | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制

如何获取算子处理一条数据记录的时间

2019-12-31 文章
Hi, 我是刚学习flink的菜鸟,现在想对一个算子,获取其处理一条数据记录的时间。请问这个应该怎么做? 谢谢 | | 张江 | | 邮箱:zjkingdom2...@163.com | 签名由 网易邮箱大师 定制