HDFS - Проверьте, закрыт ли объект FileSystem - PullRequest
0 голосов
/ 12 апреля 2019

Я использую общий экземпляр FileSystem, т. Е. FileSystem.get

У меня есть блок кода, похожий на

try {
  //Move file using FileUtils
} catch(IOException e) {
}

Этот блок выполняется несколькими потоками, то есть актерами AKKA.К сожалению, я получаю FileSystem closed exception.Я понимаю, что объект файловой системы закрывается в некоторой ситуации.Но это не из моего кода приложения, так как у меня есть только один метод close, который не вызывается перед генерацией исключения.

Итак, я хочу повторно инициализировать объект файловой системы в блоке кэша.Перед инициализацией я хочу проверить, закрыта ли FileSystem.Я не могу найти какие-либо методы в API.

IOException очень универсальный.Вот почему я хотел проверить, произошло ли исключение из-за закрытия файловой системы.

Есть предложения?

...