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