Github user jtstorck commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2971#discussion_r219377632
--- Diff:
nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java
---
@@ -266,6 +271,16 @@ public Object run() {
throw new
IOException(configuredRootDirPath.toString() + " could not be created");
}
changeOwner(context, hdfs, configuredRootDirPath,
flowFile);
+ } catch (IOException e) {
--- End diff --
Thanks for changing this to use GSSException.getMajor(). I haven't tested
a ticket expiration occurring during the execution of a call to ugi.doAs (as
opposed to the ticket having expired before ugi.doAs is invoked), but I think
it would be a good idea to move this catch block to the top level try/catch
block of the PrivelegedExceptionAction passed to ugi.doAs().
---
