Maximilian Michels created FLINK-32959:
------------------------------------------
Summary: Operator standalone mode throws NoClassDefFoundError
Key: FLINK-32959
URL: https://issues.apache.org/jira/browse/FLINK-32959
Project: Flink
Issue Type: Bug
Components: Kubernetes Operator
Affects Versions: kubernetes-operator-1.6.0
Reporter: Maximilian Michels
Fix For: kubernetes-operator-1.7.0
The standalone mode throws the following error:
{noformat}
Exception in thread "pool-7-thread-2"
org.apache.flink.shaded.guava30.com.google.common.util.concurrent.ExecutionError:
java.lang.NoClassDefFoundError:
org/apache/flink/kubernetes/operator/standalone/StandaloneKubernetesConfigOptionsInternal
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2049)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3985)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4946)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigManager.getConfig(FlinkConfigManager.java:298)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigManager.getDeployConfig(FlinkConfigManager.java:219)
at
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext.getDeployConfig(FlinkDeploymentContext.java:48)
at
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler.reconcile(AbstractFlinkResourceReconciler.java:118)
at
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:136)
at
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:56)
at
io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:138)
at
io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:96)
at
org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics.timeControllerExecution(OperatorJosdkMetrics.java:80)
at
io.javaoperatorsdk.operator.processing.Controller.reconcile(Controller.java:95)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.reconcileExecution(ReconciliationDispatcher.java:139)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleReconcile(ReconciliationDispatcher.java:119)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:89)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:62)
at
io.javaoperatorsdk.operator.processing.event.EventProcessor$ReconcilerExecutor.run(EventProcessor.java:414)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.NoClassDefFoundError:
org/apache/flink/kubernetes/operator/standalone/StandaloneKubernetesConfigOptionsInternal
at
org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder.applyTaskManagerSpec(FlinkConfigBuilder.java:279)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder.buildFrom(FlinkConfigBuilder.java:405)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigManager.generateConfig(FlinkConfigManager.java:305)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigManager$1.load(FlinkConfigManager.java:106)
at
org.apache.flink.kubernetes.operator.config.FlinkConfigManager$1.load(FlinkConfigManager.java:103)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155)
at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045)
``` {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)