I am having issues setting up my spark environment to read from a
kerberized HDFS file location.
At the moment I have tried to do the following:
def ugiDoAs[T](ugi: Option[UserGroupInformation])(code: => T) = ugi match
{
case None => code
case Some(u) => u.doAs(new PrivilegedExceptionAc
I am having issues setting up my spark environment to read from a
kerberized HDFS file location.
At the moment I have tried to do the following:
def ugiDoAs[T](ugi: Option[UserGroupInformation])(code: => T) = ugi match
{
case None => code
case Some(u) => u.doAs(new PrivilegedExceptionAc