I haven't been confronted to your use case but your error messageexplicitly says that you are not passing correctly the user "hadoop".You should use the doAs() method on UserGroupInformation in order toexecute the job with this particular user.