[FLINK-2829] [runtime] Clarify error message when Flink cannot deploy task to slot
This closes #1993 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77afe28e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77afe28e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/77afe28e Branch: refs/heads/master Commit: 77afe28eb1d5cf454f7e64be20420051c30596a2 Parents: 035f629 Author: Joshi <[email protected]> Authored: Mon May 16 14:14:23 2016 -0700 Committer: Stephan Ewen <[email protected]> Committed: Mon May 30 14:41:34 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/executiongraph/Execution.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/77afe28e/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java index a14248e..4ba58d3 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java @@ -405,8 +405,8 @@ public class Execution implements Serializable { } else { if (!(success.equals(Messages.getAcknowledge()))) { - markFailed(new Exception("Failed to deploy the task to slot " + slot + - ": Response was not of type Acknowledge")); + markFailed(new Exception("Failed to deploy the task to slot. Response was not of type 'Acknowledge', but was " + success + + "\nSlot Details: " + slot)); } } }
