gaborgsomogyi commented on issue #27877: [WIP][SPARK-30541][TESTS] Implement KafkaDelegationTokenSuite with testRetry URL: https://github.com/apache/spark/pull/27877#issuecomment-597740100 I've just double checked `ZookeeperServer` and seems like implemented it's own Kerberos authentication manually. Tried to mimic the same steps and clear the shared state in the following way without success: ``` System.setProperty(JAVA_AUTH_CONFIG, jaasConfigFile) Configuration.getConfiguration.refresh() val lcs = new LoginContext("Server") lcs.login() lcs.getSubject().getPublicCredentials().clear(); lcs.getSubject().getPrivateCredentials().clear(); val lcc = new LoginContext("Client") lcc.login() lcc.getSubject().getPublicCredentials().clear(); lcc.getSubject().getPrivateCredentials().clear(); val lck = new LoginContext("KafkaServer") lck.login() lck.getSubject().getPublicCredentials().clear(); lck.getSubject().getPrivateCredentials().clear(); ``` Now checking to execute it in a separate JVM but not sure how it will behave with `testRetry`. If I undertand the code properly retries will be executed in the exact same separate JVM which is not good for us, right?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
