Fix when hdfsBuilderConnect returns NULL, HadoopFileSystem::FileExists returns errors::NotFound exception
diff --git a/tensorflow/c/experimental/filesystem/plugins/hadoop/hadoop_filesystem.cc b/tensorflow/c/experimental/filesystem/plugins/hadoop/hadoop_filesystem.cc
index 5ff28e4..0981bdd 100644
--- a/tensorflow/c/experimental/filesystem/plugins/hadoop/hadoop_filesystem.cc
+++ b/tensorflow/c/experimental/filesystem/plugins/hadoop/hadoop_filesystem.cc
@@ -217,7 +217,7 @@
hadoop_file->connection_cache.end()) {
auto cacheFs = libhdfs->hdfsBuilderConnect(builder);
if (cacheFs == nullptr) {
- TF_SetStatusFromIOError(status, TF_NOT_FOUND, strerror(errno));
+ TF_SetStatusFromIOError(status, TF_ABORTED, strerror(errno));
return cacheFs;
}
hadoop_file->connection_cache[cacheKey] = cacheFs;
diff --git a/tensorflow/core/platform/hadoop/hadoop_file_system.cc b/tensorflow/core/platform/hadoop/hadoop_file_system.cc
index 74195db..a5db010 100644
--- a/tensorflow/core/platform/hadoop/hadoop_file_system.cc
+++ b/tensorflow/core/platform/hadoop/hadoop_file_system.cc
@@ -196,7 +196,7 @@
if (connectionCache_.find(cacheKey) == connectionCache_.end()) {
hdfsFS cacheFs = libhdfs()->hdfsBuilderConnect(builder);
if (cacheFs == nullptr) {
- return errors::NotFound(strerror(errno));
+ return errors::Aborted(strerror(errno));
}
connectionCache_[cacheKey] = cacheFs;
}
