Impersonation support in Flink

[Chan, Regina]

Hi folks,

Is Flink is able to do impersonation using UserGroupInformation? How do we make 
all the tasks run with this in a way that we wouldn't have to do it per task?


UserGroupInformation ugi = UserGroupInformation.createProxyUser( proxyUser, 
UserGroupInformation.getLoginUser());
PrivilegedExceptionAction<Void> iAction = new PrivilegedExceptionAction<Void>()
{
public Void run() throws Exception
{
              action.run();
              return null;
       }
};
ugi.doAs(iAction);



Regina Chan
Goldman Sachs - Enterprise Platforms, Data Architecture
30 Hudson Street, 37th floor | Jersey City, NY 07302 *  (212) 902-5697