experiments/STT-tensorflow
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge pull request from yuanbopeng:patch-fix

Browse Source 
PiperOrigin-RevId: 338685635
Change-Id: If2cc18d6f300fc55a55d9c0644ea5ec43e1f4c90
This commit is contained in:
TensorFlower Gardener 2020-10-23 09:19:26 -07:00
commit 7bd0d8f06d
2 changed files with 2 additions and 2 deletions
tensorflow
c/experimental/filesystem/plugins/hadoop
hadoop_filesystem.cc
core/platform/hadoop
hadoop_file_system.cc

2
tensorflow/c/experimental/filesystem/plugins/hadoop/hadoop_filesystem.cc
View File

@ -219,7 +219,7 @@ hdfsFS Connect(tf_hadoop_filesystem::HadoopFile* hadoop_file,
builder, namenode.empty() ? nullptr : namenode.c_str()); builder, namenode.empty() ? nullptr : namenode.c_str());
auto cacheFs = libhdfs->hdfsBuilderConnect(builder); auto cacheFs = libhdfs->hdfsBuilderConnect(builder);
if (cacheFs == nullptr) { if (cacheFs == nullptr) {
TF_SetStatusFromIOError(status, TF_NOT_FOUND, strerror(errno)); TF_SetStatusFromIOError(status, TF_ABORTED, strerror(errno));
return cacheFs; return cacheFs;
} }
hadoop_file->connection_cache[cacheKey] = cacheFs; hadoop_file->connection_cache[cacheKey] = cacheFs;

2
tensorflow/core/platform/hadoop/hadoop_file_system.cc
View File

@ -197,7 +197,7 @@ Status HadoopFileSystem::Connect(StringPiece fname, hdfsFS* fs) {
nn.empty() ? nullptr : nn.c_str()); nn.empty() ? nullptr : nn.c_str());
hdfsFS cacheFs = libhdfs()->hdfsBuilderConnect(builder); hdfsFS cacheFs = libhdfs()->hdfsBuilderConnect(builder);
if (cacheFs == nullptr) { if (cacheFs == nullptr) {
return errors::NotFound(strerror(errno)); return errors::Aborted(strerror(errno));
} }
connectionCache_[cacheKey] = cacheFs; connectionCache_[cacheKey] = cacheFs;
} }