lijihuaxiaomo commented on issue #12538:
URL: https://github.com/apache/hudi/issues/12538#issuecomment-2562105695
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.hadoop.security.UserGroupInformation
at
org.apache.hadoop.conf.Configuration$Resource.getRestrictParserDefault(Configuration.java:289)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.conf.Configuration$Resource.<init>(Configuration.java:262)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.conf.Configuration$Resource.<init>(Configuration.java:254)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.conf.Configuration.addResource(Configuration.java:960)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hudi.util.FlinkClientUtil.getHadoopConfiguration(FlinkClientUtil.java:71)
~[hudi-flink1.17-bundle-0.14.0.jar:0.14.0]
at
org.apache.hudi.util.FlinkClientUtil.getHadoopConf(FlinkClientUtil.java:49)
~[hudi-flink1.17-bundle-0.14.0.jar:0.14.0]
at
org.apache.hudi.configuration.HadoopConfigurations.getHadoopConf(HadoopConfigurations.java:51)
~[hudi-flink1.17-bundle-0.14.0.jar:0.14.0]
at
org.apache.hudi.util.StreamerUtil.createMetaClient(StreamerUtil.java:305)
~[hudi-flink1.17-bundle-0.14.0.jar:0.14.0]
at
org.apache.hudi.sink.common.AbstractStreamWriteFunction.initializeState(AbstractStreamWriteFunction.java:142)
~[hudi-flink1.17-bundle-0.14.0.jar:0.14.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.tryRestoreFunction(StreamingFunctionUtils.java:189)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.restoreFunctionState(StreamingFunctionUtils.java:171)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.initializeState(AbstractUdfStreamOperator.java:95)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:122)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:274)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:734)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:709)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921)
~[flink-dist-1.17.0.jar:1.17.0]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)
~[flink-dist-1.17.0.jar:1.17.0]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
~[flink-dist-1.17.0.jar:1.17.0]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_401]
Caused by: java.lang.ExceptionInInitializerError: Exception
java.lang.NoClassDefFoundError: org/apache/commons/configuration2/Configuration
[in thread "main"]
at
org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.<init>(DefaultMetricsSystem.java:43)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.<clinit>(DefaultMetricsSystem.java:41)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.security.UserGroupInformation$UgiMetrics.create(UserGroupInformation.java:148)
~[hadoop-common-3.4.1.jar:?]
at
org.apache.hadoop.security.UserGroupInformation.<clinit>(UserGroupInformation.java:264)
~[hadoop-common-3.4.1.jar:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_401]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_401]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_401]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_401]
at
org.apache.flink.runtime.util.EnvironmentInformation.getHadoopUser(EnvironmentInformation.java:215)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.runtime.util.EnvironmentInformation.logEnvironmentInfo(EnvironmentInformation.java:434)
~[flink-dist-1.17.0.jar:1.17.0]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.main(TaskManagerRunner.java:456)
~[flink-dist-1.17.0.jar:1.17.0]
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
