flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject flink git commit: [streaming] Appropriate Exception message in WriteSinkFunction
Date Mon, 14 Sep 2015 13:12:49 GMT
Repository: flink
Updated Branches:
  refs/heads/master b73fef242 -> 8acd15d82


[streaming] Appropriate Exception message in WriteSinkFunction

Closes #1119


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

Branch: refs/heads/master
Commit: 8acd15d82f4d29088d0ecda5b74479ede48b84e3
Parents: b73fef2
Author: HuangWHWHW <404823056@qq.com>
Authored: Mon Sep 14 20:02:38 2015 +0800
Committer: mbalassi <mbalassi@apache.org>
Committed: Mon Sep 14 14:56:35 2015 +0200

----------------------------------------------------------------------
 .../flink/streaming/api/functions/sink/WriteSinkFunction.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/8acd15d8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
index b25806d..27c352f 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
@@ -56,7 +56,7 @@ public abstract class WriteSinkFunction<IN> implements SinkFunction<IN>
{
 			writer.print("");
 			writer.close();
 		} catch (FileNotFoundException e) {
-			throw new RuntimeException("File not found " + path, e);
+			throw new RuntimeException("An error occurred while cleaning the file: " + e.getMessage(),
e);
 		}
 	}
 


Mime
View raw message