我有一个程序在本地集群中运行良好,但在远程集群上执行时无法正常运行。我想知道,调试远程 Flink 集群上运行的程序的最佳和常见方法是什么? 如有任何帮助,我们将不胜感激!
最佳答案
有多种方法可以在远程集群上调试 Flink 应用程序。 由于使用真正的调试器很复杂,因此我首先尝试尽可能多地记录日志以找出错误。
另一种可能有用的方法是使用 Flink 的累加器。使用它们,您可以收集一些统计信息:例如,当您有过滤器时,您可以确定有多少元素通过了过滤器等等。
最后的手段是将调试器附加到 Flink TaskManager JVM 之一。
另请查看我关于该主题的演示:http://de.slideshare.net/robertmetzger1/apache-flink-hands-on
关于apache-flink - 在远程集群上调试,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34816847/