[FLINK-20806] Correct error message in TaskExecutor.disconnectJobManagerConnection

This closes #14518.
上级 1ec147c2
......@@ -1593,7 +1593,8 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway {
final FlinkException failureCause =
new FlinkException(
"JobManager responsible for " + jobId + " lost the leadership.", cause);
String.format("Disconnect from JobManager responsible for %s.", jobId),
cause);
while (tasks.hasNext()) {
tasks.next().failExternally(failureCause);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册