Author: minoru
Date: Mon Jun 24 12:51:40 2013
New Revision: 1496008
URL: http://svn.apache.org/r1496008
Log: (empty)
Modified:
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/agents/output/hdfs/HDFSOutputConnector.java
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/hdfs/HDFSRepositoryConnector.java
Modified:
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/agents/output/hdfs/HDFSOutputConnector.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/agents/output/hdfs/HDFSOutputConnector.java?rev=1496008&r1=1496007&r2=1496008&view=diff
==============================================================================
---
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/agents/output/hdfs/HDFSOutputConnector.java
(original)
+++
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/agents/output/hdfs/HDFSOutputConnector.java
Mon Jun 24 12:51:40 2013
@@ -133,10 +133,13 @@ public class HDFSOutputConnector extends
*/
try {
fileSystem = FileSystem.get(new URI(nameNode), config, user);
- } catch (URISyntaxException e) {
- } catch (IOException e) {
- } catch (InterruptedException e) {
- }
+ } catch (URISyntaxException e) {
+ Logging.connectors.warn("HDFS: Node name error: " + e.getMessage(), e);
+ } catch (IOException e) {
+ Logging.connectors.warn("HDFS: File system error: " + e.getMessage(), e);
+ } catch (InterruptedException e) {
+ Logging.connectors.warn("HDFS: File system error: " + e.getMessage(), e);
+ }
}
/** Close the connection. Call this before discarding the connection.
Modified:
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/hdfs/HDFSRepositoryConnector.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/hdfs/HDFSRepositoryConnector.java?rev=1496008&r1=1496007&r2=1496008&view=diff
==============================================================================
---
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/hdfs/HDFSRepositoryConnector.java
(original)
+++
manifoldcf/branches/CONNECTORS-728/connectors/hdfs/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/hdfs/HDFSRepositoryConnector.java
Mon Jun 24 12:51:40 2013
@@ -94,8 +94,11 @@ public class HDFSRepositoryConnector ext
try {
fileSystem = FileSystem.get(new URI(nameNode), config, user);
} catch (URISyntaxException e) {
+ Logging.connectors.warn("HDFS: Node name error: " + e.getMessage(), e);
} catch (IOException e) {
+ Logging.connectors.warn("HDFS: File system error: " + e.getMessage(), e);
} catch (InterruptedException e) {
+ Logging.connectors.warn("HDFS: File system error: " + e.getMessage(), e);
}
}