我有一个程序在本地集群中运行良好，但在远程集群上执行时运行不正常。我想知道，调试运行在远程flink集群上的程序的最佳和常见方法是什么？感谢您的帮助！
e0bqpujr1#
有几种方法可以调试远程集群上的flink应用程序。因为使用真正的调试器很复杂，所以我首先会尽可能多地记录日志以找出错误。另一种可能有用的方法是使用Flink的蓄能器。使用它们，您可以收集一些统计信息：例如，当您有一个过滤器时，您可以确定有多少元素通过了过滤器，等等。最后一种方法是将调试器附加到flink taskmanager JVM之一。另外，请看我的专题介绍：http://de.slideshare.net/robertmetzger1/apache-flink-hands-on
1条答案
按热度按时间e0bqpujr1#
有几种方法可以调试远程集群上的flink应用程序。因为使用真正的调试器很复杂，所以我首先会尽可能多地记录日志以找出错误。
另一种可能有用的方法是使用Flink的蓄能器。使用它们，您可以收集一些统计信息：例如，当您有一个过滤器时，您可以确定有多少元素通过了过滤器，等等。
最后一种方法是将调试器附加到flink taskmanager JVM之一。
另外，请看我的专题介绍：http://de.slideshare.net/robertmetzger1/apache-flink-hands-on