You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/10/18 06:22:58 UTC
[2/2] camel git commit: CAMEL-11920: camel-hdfs2 not working in osgi
using documented HdfsOsgiHelper
CAMEL-11920: camel-hdfs2 not working in osgi using documented HdfsOsgiHelper
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/337252c5
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/337252c5
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/337252c5
Branch: refs/heads/camel-2.19.x
Commit: 337252c5e44d9e6f24c98a6bf93812da5b3829f7
Parents: 9d6bc07
Author: Andrea Tarocchi <at...@redhat.com>
Authored: Tue Oct 17 19:11:40 2017 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Wed Oct 18 08:22:43 2017 +0200
----------------------------------------------------------------------
components/camel-hdfs2/pom.xml | 4 +++-
.../java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java | 6 +++++-
2 files changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/337252c5/components/camel-hdfs2/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-hdfs2/pom.xml b/components/camel-hdfs2/pom.xml
index ca3705a..d54857d 100644
--- a/components/camel-hdfs2/pom.xml
+++ b/components/camel-hdfs2/pom.xml
@@ -44,7 +44,9 @@
org.apache.hadoop.hdfs.security.token.delegation,
org.apache.hadoop.hdfs.protocol,
org.apache.hadoop.hdfs.protocol.proto,
- org.apache.hadoop.hdfs.protocol.datatransfer
+ org.apache.hadoop.hdfs.protocol.datatransfer,
+ org.apache.hadoop.net,
+ org.apache.hadoop.ipc
</camel.osgi.import.additional>
<camel.osgi.activator>
org.apache.camel.component.hdfs2.osgi.HdfsActivator
http://git-wip-us.apache.org/repos/asf/camel/blob/337252c5/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java
----------------------------------------------------------------------
diff --git a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java
index 5077fbd..d63a592 100644
--- a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java
+++ b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsOsgiHelper.java
@@ -41,13 +41,17 @@ public class HdfsOsgiHelper {
// get bundle classloader for camel-hdfs2 bundle
ClassLoader cl = getClass().getClassLoader();
Configuration conf = new Configuration();
+ // set that as the hdfs configuration's classloader
+ conf.setClassLoader(cl);
for (String key : fileSystems.keySet()) {
URI uri = URI.create(key);
conf.setClass(String.format("fs.%s.impl", uri.getScheme()), cl.loadClass(fileSystems.get(key)), FileSystem.class);
+ LOG.debug("Successfully loaded class: {}", fileSystems.get(key) );
FileSystem.get(uri, conf);
+ LOG.debug("Successfully got uri: {} from FileSystem Object", uri );
}
} catch (Exception e) {
- LOG.debug(e.getMessage());
+ LOG.debug(e.getMessage(), e);
}
}