flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [84/92] [abbrv] git commit: Improve exception messages for file output format when target file cannot be created.
Date Tue, 22 Jul 2014 10:41:24 GMT
Improve exception messages for file output format when target file cannot be created.


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/8ed2b76d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/8ed2b76d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/8ed2b76d

Branch: refs/heads/travis_test
Commit: 8ed2b76dd3f8b64c93e7610340f5d063bf0ade21
Parents: 5b34c0b
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue Jul 15 17:39:58 2014 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Wed Jul 16 18:49:50 2014 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/api/common/io/FileOutputFormat.java    | 4 ++--
 .../flink/runtime/iterative/task/IterationTailPactTask.java      | 1 +
 2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/8ed2b76d/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
index 168ebed..ad771be 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
@@ -217,7 +217,7 @@ public abstract class FileOutputFormat<IT> implements OutputFormat<IT>,
Initiali
 				// prepare local output path. checks for write mode and removes existing files in case
of OVERWRITE mode
 				if(!fs.initOutPathLocalFS(p, writeMode, false)) {
 					// output preparation failed! Cancel task.
-					throw new IOException("Output path could not be initialized. Canceling task...");
+					throw new IOException("Output path '" + p.toString() + "' could not be initialized.
Canceling task...");
 				}
 			}
 			else {
@@ -225,7 +225,7 @@ public abstract class FileOutputFormat<IT> implements OutputFormat<IT>,
Initiali
 				
 				if(!fs.initOutPathLocalFS(p, writeMode, true)) {
 					// output preparation failed! Cancel task.
-					throw new IOException("Output directory could not be created. Canceling task...");
+					throw new IOException("Output directory '" + p.toString() + "' could not be created.
Canceling task...");
 				}
 			}
 		}

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/8ed2b76d/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailPactTask.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailPactTask.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailPactTask.java
index 2cdc58c..570630f 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailPactTask.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailPactTask.java
@@ -108,6 +108,7 @@ public class IterationTailPactTask<S extends Function, OT> extends
AbstractItera
 			catch (NullPointerException e) {
 				boolean terminationRequested = terminationRequested();
 				System.out.println("Nullpoint exception when termination requested was " + terminationRequested);
+				e.printStackTrace();
 			}
 
 			// check if termination was requested


Mime
View raw message