pushgateway 要定期清理不然内存很容易撑爆。
利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏前言 虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB。InfluxDB是一个由Go...
pushgateway 要定期清理不然内存很容易撑爆。
利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏前言 虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB。InfluxDB是一个由Go...
大佬问一下,upsert-kafka的代码官网没有啊,哪里搞到的,自己编译的吗?
FLINK 1.12 支持upsertSql 不再去使用了JDBCUpsertSINK了,kafka也支持upsert了最后数据库结果如下: 每次都是更新替换,这样的话省去很多麻烦,不用转datastream在处理了,而且1.12支持upsert-kafka,最后数据叠加如下: upsert-...