[hotfix] [client] Unwrap SerializedThrowable in client log statements when possible
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9623be2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c9623be2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c9623be2 Branch: refs/heads/table-retraction Commit: c9623be2ac1ce44c1d04eeda336723b92e2fadf9 Parents: 91b2d6f Author: Stephan Ewen <se...@apache.org> Authored: Tue May 2 22:10:40 2017 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Tue May 2 22:49:46 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/client/JobClientActor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c9623be2/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java index 368a2b6..a0bf97d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java @@ -34,6 +34,7 @@ import org.apache.flink.runtime.messages.JobClientMessages; import org.apache.flink.runtime.messages.JobClientMessages.JobManagerActorRef; import org.apache.flink.runtime.messages.JobClientMessages.JobManagerLeaderAddress; import org.apache.flink.runtime.messages.JobManagerMessages; +import org.apache.flink.runtime.util.SerializedThrowable; import org.apache.flink.util.Preconditions; import scala.concurrent.duration.FiniteDuration; @@ -287,7 +288,8 @@ public abstract class JobClientActor extends FlinkUntypedActor implements Leader System.out.println(message.toString()); } } else { - LOG.info(message.toString(), message.error()); + Throwable error = SerializedThrowable.get(message.error(), getClass().getClassLoader()); + LOG.info(message.toString(), error); if (sysoutUpdates) { System.out.println(message.toString()); message.error().printStackTrace(System.out);