apache.org/projects/flink/flink-docs-release-1.7/monitoring/metrics.html#registering-metrics 2 https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/metrics.html#reporter Flink指标体系 – 监控Apache Flink应用程序(入门) 进度和吞吐量监控 – 10 3 https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/#task-chaining-and-resource-groups 4 进度和吞吐量监控 知道您的应用程序正在运行并且检查点正常工作是件好事，但是它并不能告诉您应用程序是否正在实际取得进 监控Apache Flink应用程序(入门) 进度和吞吐量监控 – 15 4 https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/metrics.html#latency-tracking 2. During periods of high load or during recovery, events

jar # -rw-r--r-- 1 dianfu staff 295K 10 18 20:43 log4j-api-2.17.1.jar # -rw-r--r-- 1 dianfu staff 1.7M 10 18 20:43 log4j-core-2.17.1.jar # -rw-r--r-- 1 dianfu staff 24K 10 18 20:43 log4j-slf4j-impl-2 jar -rw-r--r-- 1 duanchen staff 295K Oct 19 16:02 log4j-api-2.17.1.jar -rw-r--r-- 1 duanchen staff 1.7M Oct 19 16:02 log4j-core-2.17.1.jar -rw-r--r-- 1 duanchen staff 24K Oct 19 16:02 log4j-slf4j-impl-2

jar # -rw-r--r-- 1 dianfu staff 295K 10 18 20:43 log4j-api-2.17.1.jar # -rw-r--r-- 1 dianfu staff 1.7M 10 18 20:43 log4j-core-2.17.1.jar # -rw-r--r-- 1 dianfu staff 24K 10 18 20:43 log4j-slf4j-impl-2 jar -rw-r--r-- 1 duanchen staff 295K Oct 19 16:02 log4j-api-2.17.1.jar -rw-r--r-- 1 duanchen staff 1.7M Oct 19 16:02 log4j-core-2.17.1.jar -rw-r--r-- 1 duanchen staff 24K Oct 19 16:02 log4j-slf4j-impl-2

Double, Double)] = keyedData .flatMap(new TemperatureAlertFunction(1.7)) Using state in Flink 15 KeyedStream State access inside the flatMap will be scoped to the key