【发布时间】：2018-02-27 23:10:40
【问题描述】：
我正在尝试在独立的 Flink 集群上运行 Python Flink 应用程序。该应用程序在单节点集群上运行良好，但在多节点集群上引发以下错误。 java.lang.Exception: The user defined 'open()' method caused an exception: An error occurred while copying the file。请帮我解决这个问题。谢谢
我正在尝试执行的应用程序具有以下代码。
from flink.plan.Environment import get_environment
from flink.plan.Constants import INT, STRING, WriteMode
env = get_environment()
data = env.from_elements("Hello")
data.map(lambda x: list(x)).output()
env.execute()
【问题讨论】：
-
请提供
open()方法的代码和完整的堆栈跟踪。到目前为止，您提供的信息无法为您提供帮助。 -
open() 函数实际上不是用户定义的，但我似乎没有找到解决这个问题的方法。只有在多节点集群中执行时，此问题仍然存在。
标签： apache-flink