You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/05/03 12:10:47 UTC
[40/50] [abbrv] flink git commit: [hotfix] [client] Unwrap
SerializedThrowable in client log statements when possible
[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);