You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/06/03 14:24:17 UTC
git commit: STREAMS-104 | Changed Exceptions caught to be broader
Repository: incubator-streams
Updated Branches:
refs/heads/master d4d95ccf0 -> 71e1a9e06
STREAMS-104 | Changed Exceptions caught to be broader
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/71e1a9e0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/71e1a9e0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/71e1a9e0
Branch: refs/heads/master
Commit: 71e1a9e064250dbc22fab91b5aa155ada6cb7d40
Parents: d4d95cc
Author: mfranklin <mf...@apache.org>
Authored: Tue Jun 3 08:24:08 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Tue Jun 3 08:24:08 2014 -0400
----------------------------------------------------------------------
.../main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/71e1a9e0/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
index 162461b..5131696 100644
--- a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
+++ b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
@@ -150,13 +150,13 @@ public class WebHdfsPersistWriter implements StreamsPersistWriter, Flushable, Cl
try{
resetFile();
this.currentWriter.write(line);
- } catch (IOException io) {
+ } catch (Exception io) {
LOGGER.warn("Failed to write even after creating a new file. Attempting to reconnect", io);
connectToWebHDFS();
resetFile();
try {
this.currentWriter.write(line);
- } catch (IOException ex) {
+ } catch (Exception ex) {
LOGGER.error("Failed to write to HDFS after reconnecting client. Terminating writer.", ex);
throw new RuntimeException(e);
}