240 发简信
IP属地:青海
  • 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-...