zyn-95677 commented on issue #12538:
URL: https://github.com/apache/hudi/issues/12538#issuecomment-3668527542

   > 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.(Configuration.java:262) 
~[hadoop-common-3.4.1.jar:?] at 
org.apache.hadoop.conf.Configuration$Resource.(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 o
 
rg.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.apac
 he.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.(DefaultMetricsSystem.java:43)
 ~[hadoop-common-3.4.1.jar:?] at 
org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.(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.(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(D
 elegatingMethodAccessorImpl.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]
   
   how to resolve problem


-- 
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]

Reply via email to