flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/8] flink git commit: [hotfix] [client] Unwrap SerializedThrowable in client log statements when possible
Date Tue, 02 May 2017 21:47:26 GMT
[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/master
Commit: c9623be2ac1ce44c1d04eeda336723b92e2fadf9
Parents: 91b2d6f
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue May 2 22:10:40 2017 +0200
Committer: Stephan Ewen <sewen@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);


Mime
View raw message