........................................................................................ 16 4.13 JVM Metrics........................................................................................... Flink作业监控的基础是它的度量系统，该系统由两个部分组成: Metrics和MetricsReporters。 1.1 Metrics Flink提供了一套全面的内置Metrics: • JVM堆/非堆/直接内存的使用情况(任务粒度) • 作业重启次数(作业粒度) • 每秒处理的数据量(操作符粒度) • ...... 作为用户，您可以并且应该向函数中添加应用程序相关的metrics。这些 Dashboard Panel Figure 5: Latency distribution between a source and a single sink subtask. 4.13 JVM Metrics So far we have only looked at Flink-specific metrics. As long as latency & throughput of your

的架构变化 Runtime Distributed Streaming Dataflow Query Processor DAG & StreamOperator Local Single JVM Cloud GCE, EC2 Cluster Standalone, YARN Runtime Distributed Streaming Dataflow DataStream API DataSet API Batch Processing Table API & SQL Relational Table API & SQL Relational Local Single JVM Cloud GCE, EC2 Cluster Standalone, YARN DataStream Physical 统一 Operator 抽象 Pull-based operator

Common options you might need to adjust: jobmanager.heap.size: JVM heap size for the JobManager (coordinator). taskmanager.heap.size: JVM heap size for the TaskManagers (workers). parallelism.default:

9-x86_64.egg/pyflink/table/environment_ ˓→settings.py", line 267, in in_streaming_mode get_gateway().jvm.EnvironmentSettings.inStreamingMode()) File "/Users/dianfu/code/src/github/pyflink-faq/testing/.venv/lib/python3

9-x86_64.egg/pyflink/table/environment_ ˓→settings.py", line 267, in in_streaming_mode get_gateway().jvm.EnvironmentSettings.inStreamingMode()) File "/Users/dianfu/code/src/github/pyflink-faq/testing/.venv/lib/python3