apache-flink - 在远程集群上调试

标签 apache-flink

我有一个程序在本地集群中运行良好,但在远程集群上执行时无法正常运行。我想知道,调试远程 Flink 集群上运行的程序的最佳和常见方法是什么? 如有任何帮助,我们将不胜感激!

最佳答案

有多种方法可以在远程集群上调试 Flink 应用程序。 由于使用真正的调试器很复杂,因此我首先尝试尽可能多地记录日志以找出错误。

另一种可能有用的方法是使用 Flink 的累加器。使用它们,您可以收集一些统计信息:例如,当您有过滤器时,您可以确定有多少元素通过了过滤器等等。

最后的手段是将调试器附加到 Flink TaskManager JVM 之一。

另请查看我关于该主题的演示:http://de.slideshare.net/robertmetzger1/apache-flink-hands-on

关于apache-flink - 在远程集群上调试,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34816847/

相关文章:

java - flink 是否以批处理模式动态减少

apache-flink - 如何将flink任务或背压相关指标导出到prometheus?

java - Apache 弗林克 : read file from HDFS

java - Flink Python 自定义连接器/源代码

kubernetes - Flink HA JobManager 集群无法选举领导者

apache-flink - Flink流: Data stream that gets controlled by control stream

java - 在本地执行示例 Flink 程序

apache-flink - flink 如何处理早期事件?忽略或创建单独的窗口?

hadoop - 如何在Flink中使用Hadoop的MapFileOutputFormat?

apache-flink - 在 Apache flink 中的节点之间共享数据集的最佳方式是什么?