flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chan, Regina" <Regina.C...@gs.com>
Subject Impersonation support in Flink
Date Mon, 23 Oct 2017 17:52:05 GMT
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


Mime
View raw message