最近在使用arthas诊断工具, 诊断java服务的一些问题, 突然想到能不能使用arthas诊断flink的jobManager和taskManager呢? 答案是可以的.下载tunnel-server的jar包使用的是Arthas Tunnel方式.第一步: 先启动一个 tunnel-server服务,在服务器:10.0.16.1 执行java -jar -Dserver.port=4433

1,软件安装:grafana+prometheus 安装教程请参考文章:安装教程2,flink配置方案一: 修改文件conf/flink-conf.yamlmetrics.reporter.promgateway.class: org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter#这里填写安装的prometheusGat

flinkSql的时间窗口,可以将一段时间内的数据进行聚合计算. 但是有时, 我们希望可以在时间窗口截止前, 就可以看到结果.一种方案是: 使用嵌套的时间窗口,另一种方案是, 在代码进行配置.我们这里说下如何在代码里进行配置比如,时间窗口为 12小时-12小时 (24小时为一个窗口), 但是希望每5分钟就需要输出一次结果.配置如下:Configuration conf = new Configur

这里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题，有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能，丰富你的文章UML 图表FLowchart流程图导出与导入导出导入欢迎使用Mar

flink运行时, 出现akka timeout异常ERROR akka.remote.Remoting - Association to [akka.tcp://flink@xxxxx:36569有可能的原因是 jdk版本不对升级jdk版本, 将版本(jdk1.8.0_11 )升至jdk1.8.0_221或之后，重新启动集群，重新提交作业，可以正常运行...