Hi Dev Team,

I am  seeing that even though fs.uri="file:///" it gets the hdfs FileSystem
probably because i have HADOOP_HOME is set and hadoop config is getting
picked up. is that right or I m missing something here ?
for ex: this line this.jobConfDirFileSystem =
this.jobConfDirPath.getFileSystem(new Configuration()); should get local
file system when fs.uri is set to "file:///" right?

basically we are using hadooo configuration class to get the utilmate
configs and Configuration.get(name="fs.defaultFS", defaultValue="file:///")
will always get fs.defaultFS from core-site.xml since that is in the
classpath.

can somebody please verify and tell if there is a way to enforce FileSystem
to be local ( basically usefs.uri from gobblin config) ?

Thanks
Jay

Reply via email to