【代码】Spark任务资源分配, 并行度, Task数, 落表文件数。

在较新版本的Flink中，配置metrics reporter的方式已经改变，不再直接配置。对于PrometheusPushGatewayReporter，工厂类应该是。通过查看日志发现，该方式对老的版本有效果，针对新版本无效。因此，我们需要修改flink-conf.yaml中的配置，将。，并指定对应的工厂类。