You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/11 18:25:00 UTC
[jira] [Created] (FLINK-38502) A number of Hadoop related tests failing with UnsupportedOperationException: getSubject is not supported
Sergey Nuyanzin created FLINK-38502:
---------------------------------------
Summary: A number of Hadoop related tests failing with UnsupportedOperationException: getSubject is not supported
Key: FLINK-38502
URL: https://issues.apache.org/jira/browse/FLINK-38502
Project: Flink
Issue Type: Sub-task
Reporter: Sergey Nuyanzin
for instance
{{MemoryExecutionGraphInfoStoreITCase#testPutSuspendedJobOnClusterShutdown}}
fails as
{noformat}
org.apache.flink.util.FlinkRuntimeException: java.lang.UnsupportedOperationException: getSubject is not supported
at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.lambda$obtainDelegationTokensAndGetNextRenewal$0(DefaultDelegationTokenManager.java:281)
at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:214)
at java.base/java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1788)
at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:570)
at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:560)
at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:265)
at java.base/java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:698)
at java.base/java.util.stream.ReferencePipeline.min(ReferencePipeline.java:744)
at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.obtainDelegationTokensAndGetNextRenewal(DefaultDelegationTokenManager.java:286)
at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.obtainDelegationTokens(DefaultDelegationTokenManager.java:242)
at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:432)
at org.apache.flink.runtime.dispatcher.MemoryExecutionGraphInfoStoreITCase.testPutSuspendedJobOnClusterShutdown(MemoryExecutionGraphInfoStoreITCase.java:57)
at java.base/java.lang.reflect.Method.invoke(Method.java:565)
at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Caused by: java.lang.UnsupportedOperationException: getSubject is not supported
at java.base/javax.security.auth.Subject.getSubject(Subject.java:277)
at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:700)
at org.apache.flink.runtime.security.token.hadoop.HadoopFSDelegationTokenProvider.delegationTokensRequired(HadoopFSDelegationTokenProvider.java:103)
at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.lambda$obtainDelegationTokensAndGetNextRenewal$0(DefaultDelegationTokenManager.java:259)
... 14 more
{noformat}
The reason seems same: Security manager removal
It looks like there is some activity about that in Hadoop https://github.com/apache/hadoop/pull/7892
and https://issues.apache.org/jira/browse/HADOOP-19574
--
This message was sent by Atlassian Jira
(v8.20.10#820010)