You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had searched in the issues and found no similar issues.
Java Version
JDK 11
Scala Version
2.12.x
StreamPark Version
2.1.4
Flink Version
1.19.1
deploy mode
kubernetes-application
What happened
The pod keeps rebooting.
Error Exception
2024-07-19T18:09:28.721633864+08:00 ==============flinkSql==============
2024-07-19T18:09:28.721638642+08:00
2024-07-19T18:09:28.721649860+08:00 CREATE TABLE datagen (
f_sequence INT,
2024-07-19T18:09:28.721660099+08:00 f_random INT,
2024-07-19T18:09:28.721665170+08:00 f_random_str STRING,
ts AS localtimestamp,
2024-07-19T18:09:28.721677430+08:00 WATERMARK FOR ts AS ts
) WITH (
2024-07-19T18:09:28.721720543+08:00 'connector' = 'datagen',
2024-07-19T18:09:28.721726618+08:00 -- optional options --
2024-07-19T18:09:28.721731855+08:00 'rows-per-second'='5',
'fields.f_sequence.kind'='sequence',
2024-07-19T18:09:28.722042314+08:00 'fields.f_sequence.start'='1',
2024-07-19T18:09:28.722050076+08:00 'fields.f_sequence.end'='500',
2024-07-19T18:09:28.722057148+08:00 'fields.f_random.min'='1',
2024-07-19T18:09:28.722063189+08:00 'fields.f_random.max'='500',
'fields.f_random_str.length'='10'
2024-07-19T18:09:28.722072624+08:00 );
2024-07-19T18:09:28.722077142+08:00
2024-07-19T18:09:28.722081826+08:00 CREATE TABLE print_table (
2024-07-19T18:09:28.722086846+08:00 f_sequence INT,
2024-07-19T18:09:28.722091532+08:00 f_random INT,
2024-07-19T18:09:28.722096080+08:00 f_random_str STRING
) WITH (
2024-07-19T18:09:28.722105502+08:00 'connector' = 'print'
2024-07-19T18:09:28.722110057+08:00 );
2024-07-19T18:09:28.722114349+08:00
2024-07-19T18:09:28.722119655+08:00 INSERT INTO print_table select f_sequence,f_random,f_random_str from datagen;
2024-07-19T18:09:28.722128732+08:00 ============================
2024-07-19T18:09:28.722133080+08:00
2024-07-19T18:09:28.722137697+08:00
2024-07-19T18:09:28.722141978+08:00
2024-07-19T18:09:28.725466475+08:00
_____ __ __
2024-07-19T18:09:28.725485615+08:00 / ___// /_________ ____ _____ ___ ____ ____ ______/ /__
2024-07-19T18:09:28.725534754+08:00 \__ \/ __/ ___/ _ \/ __ `/ __ `__ \/ __ \ __ `/ ___/ //_/
2024-07-19T18:09:28.725542374+08:00 ___/ / /_/ / / __/ /_/ / / / / / / /_/ / /_/ / / / ,<
2024-07-19T18:09:28.725549410+08:00 /____/\__/_/ \___/\__,_/_/ /_/ /_/ ____/\__,_/_/ /_/|_|
/_/
2024-07-19T18:09:28.725560780+08:00
Version: 2.1.4
2024-07-19T18:09:28.725595764+08:00 WebSite: https://streampark.apache.org
2024-07-19T18:09:28.725615873+08:00 GitHub : https://github.com/apache/incubator-streampark
2024-07-19T18:09:28.725622450+08:00 Info : FlinkStreamTable testappmode Starting...
2024-07-19T18:09:28.725942538+08:00 Time : 2024-07-19T10:09:28.725558
2024-07-19T18:09:28.725961113+08:00
2024-07-19T18:09:28.725966577+08:00
2024-07-19T18:09:38.617714120+08:00 2024-07-19 10:09:38,617 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Could not resolve ResourceManager address pekko.tcp://flink@testappmode.streampark:6123/user/rpc/resourcemanager_*, retrying in 10000 ms: Could not connect to rpc endpoint under address pekko.tcp://flink@testappmode.streampark:6123/user/rpc/resourcemanager_*.
2024-07-19T18:09:53.055661384+08:00 2024-07-19 10:09:53,055 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Stopping credential renewal
2024-07-19 10:09:53,055 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Stopped credential renewal
2024-07-19T18:09:53.056056108+08:00 2024-07-19 10:09:53,055 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Closing the slot manager.
2024-07-19T18:09:53.056104631+08:00 2024-07-19 10:09:53,055 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Suspending the slot manager.
2024-07-19T18:09:53.071418366+08:00 2024-07-19 10:09:53,057 ERROR org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Fatal error occurred in ResourceManager.
org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException: Could not start the ResourceManager pekko.tcp://flink@testappmode.streampark:6123/user/rpc/resourcemanager_1
2024-07-19T18:09:53.071461942+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:259) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071468451+08:00 at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:198) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071474856+08:00 at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StoppedState.lambda$start$0(PekkoRpcActor.java:618) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071481451+08:00 at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StoppedState.start(PekkoRpcActor.java:617) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071493236+08:00 at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleControlMessage(PekkoRpcActor.java:190) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071498458+08:00 at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071522265+08:00 at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071528786+08:00 at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071534594+08:00 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071540704+08:00 at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071545991+08:00 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071551080+08:00 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071556542+08:00 at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071568727+08:00 at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071580195+08:00 at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071585147+08:00 at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071590441+08:00 at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.071604294+08:00 at java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?]
2024-07-19T18:09:53.071611811+08:00 at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) [?:?]
2024-07-19T18:09:53.071618622+08:00 at java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?]
2024-07-19T18:09:53.071624945+08:00 at java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?]
2024-07-19T18:09:53.071630926+08:00 at java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?]
Caused by: org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException: Cannot initialize resource provider.
2024-07-19T18:09:53.071642798+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:202) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071648737+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071668244+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071678407+08:00 ... 25 more
2024-07-19T18:09:53.071685737+08:00 Caused by: org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.KubernetesClientException: Operation: [list] for kind: [Pod] with name: [null] in namespace: [streampark] failed.
2024-07-19T18:09:53.071714073+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:159) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071718770+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:452) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071723198+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:97) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071727228+08:00 at org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getPodsWithLabels(Fabric8FlinkKubeClient.java:199) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071731348+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.recoverWorkerNodesFromPreviousAttempts(KubernetesResourceManagerDriver.java:266) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071735334+08:00 at org.apache.flink.kubernetes.KubernetesRe
sourceManagerDriver.initializeInternal(KubernetesResourceManagerDriver.java:127) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071740671+08:00 at org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver.initialize(AbstractResourceManagerDriver.java:92) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071746128+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:196) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071751860+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071764286+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071770954+08:00 ... 25 more
Caused by: java.io.IOException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
2024-07-19T18:09:53.071784356+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.OperationSupport.waitForResult(OperationSupport.java:504) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071790714+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:450) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071795934+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:97) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071800560+08:00 at org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getPodsWithLabels(Fabric8FlinkKubeClient.java:199) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.recoverWorkerNodesFromPreviousAttempts(KubernetesResourceManagerDriver.java:266) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071811294+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.initializeInternal(KubernetesResourceManagerDriver.java:127) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071816151+08:00 at org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver.initialize(AbstractResourceManagerDriver.java:92) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071821026+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:196) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071826790+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071840445+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071845575+08:00 ... 25 more
2024-07-19T18:09:53.071851752+08:00 Caused by: javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
2024-07-19T18:09:53.071857724+08:00 at sun.security.ssl.Alert.createSSLException(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071862995+08:00 at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071868214+08:00 at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071899204+08:00 at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071908686+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071914088+08:00 at sun.security.ssl.CertificateMessage$T
13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071924462+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071929878+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071934810+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071939910+08:00 at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071944901+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071950044+08:00 at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071955125+08:00 at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071960077+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.071971143+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071976690+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071982209+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.071987843+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072003121+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072017354+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072022572+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072028007+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072177503+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072187478+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072205433+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072210334+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072221530+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072227030+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072237946+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072243709+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072264441+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072270181+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
at java.lang.Thread.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072281774+08:00 Caused by: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
at sun.security.validator.PKIXValidator.doBuild(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072294426+08:00 at sun.security.validator.PKIXValidator.engineValidate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072299896+08:00 at sun.security.validator.Validator.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072305424+08:00 at sun.security.ssl.X509TrustManagerImpl.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072310795+08:00 at sun.security.ssl.X509TrustManagerImpl.checkTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072316643+08:00 at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072321947+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
at sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072339719+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072345021+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072355592+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072361637+08:00 at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072367829+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072373606+08:00 at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072380443+08:00 at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072386353+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072391186+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072403745+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072410086+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072415447+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072420688+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072426158+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072431314+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072446699+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072451703+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072474371+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072479605+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072518240+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072529206+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072534274+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072539411+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072557281+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072562991+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072568779+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072573963+08:00 at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
2024-07-19T18:09:53.072585433+08:00 at sun.security.provider.certpath.SunCertPathBuilder.build(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072590753+08:00 at sun.security.provider.certpath.SunCertPathBuilder.engineBuild(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072614793+08:00 at java.security.cert.CertPathBuilder.build(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072620504+08:00 at sun.security.validator.PKIXValidator.doBuild(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072625705+08:00 at sun.security.validator.PKIXValidator.engineValidate(Unknown Source) ~[?:?]
at sun.security.validator.Validator.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072635941+08:00 at sun.security.ssl.X509TrustManagerImpl.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072641478+08:00 at sun.security.ssl.X509TrustManagerImpl.checkTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072647138+08:00 at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072653118+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072658405+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072663906+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072669080+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072674228+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072679344+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072684592+08:00 at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072689823+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072712494+08:00 at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072718069+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072730055+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072735376+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072740671+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072745952+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072757151+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072762503+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072768921+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072775037+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072804506+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072810029+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072815230+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072820310+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072830470+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072835529+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072845432+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072850589+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072855959+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072861042+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.072873406+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
2024-07-19T18:09:53.072878964+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
at java.lang.Thread.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.077716512+08:00 2024-07-19 10:09:53,074 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error occurred in the cluster entrypoint.
2024-07-19T18:09:53.077749693+08:00 org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException: Could not start the ResourceManager pekko.tcp://flink@testappmode.streampark:6123/user/rpc/resourcemanager_1
at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:259) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077761964+08:00 at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:198) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077768177+08:00 at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StoppedState.lambda$start$0(PekkoRpcActor.java:618) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077773686+08:00 at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077779756+08:00 at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StoppedState.start(PekkoRpcActor.java:617) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077785545+08:00 at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleControlMessage(PekkoRpcActor.java:190) ~[flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077796431+08:00 at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077806627+08:00 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077812120+08:00 at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077817185+08:00 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077822121+08:00 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077827631+08:00 at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077837872+08:00 at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077842974+08:00 at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077847991+08:00 at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077881196+08:00 at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
2024-07-19T18:09:53.077891645+08:00 at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253) [flink-rpc-akka650cd1ba-9cd1-4a03-8a95-f76fa07438cb.jar:1.19.1]
at java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?]
2024-07-19T18:09:53.077907818+08:00 at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) [?:?]
2024-07-19T18:09:53.077913371+08:00 at java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?]
2024-07-19T18:09:53.077918500+08:00 at java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?]
2024-07-19T18:09:53.077928830+08:00 Caused by: org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException: Cannot initialize resource provider.
2024-07-19T18:09:53.077933911+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:202) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077939125+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077958769+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077964376+08:00 ... 25 more
Caused by: org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.KubernetesClientException: Operation: [list] for kind: [Pod] with name: [null] in namespace: [streampark] failed.
2024-07-19T18:09:53.077976033+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:159) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:452) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077986397+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:97) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077991282+08:00 at org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getPodsWithLabels(Fabric8FlinkKubeClient.java:199) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.077996755+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.recoverWorkerNodesFromPreviousAttempts(KubernetesResourceManagerDriver.java:266) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078001529+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.initializeInternal(KubernetesResourceManagerDriver.java:127) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver.initialize(AbstractResourceManagerDriver.java:92) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078011782+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:196) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078016556+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078030746+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078035952+08:00 ... 25 more
Caused by: java.io.IOException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
2024-07-19T18:09:53.078047236+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.OperationSupport.waitForResult(OperationSupport.java:504) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078052419+08:00 at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:450) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.BaseOperation.list(BaseOperation.java:97) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078063913+08:00 at org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getPodsWithLabels(Fabric8FlinkKubeClient.java:199) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078069347+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.recoverWorkerNodesFromPreviousAttempts(KubernetesResourceManagerDriver.java:266) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078075209+08:00 at org.apache.flink.kubernetes.KubernetesResourceManagerDriver.initializeInternal(KubernetesResourceManagerDriver.java:127) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078081259+08:00 at org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver.initialize(AbstractResourceManagerDriver.java:92) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078086087+08:00 at org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager.initialize(ActiveResourceManager.java:196) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.runtime.resourcemanager.ResourceManager.startResourceManagerServices(ResourceManager.java:283) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078096760+08:00 at org.apache.flink.runtime.resourcemanager.ResourceManager.onStart(ResourceManager.java:254) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078102148+08:00 ... 25 more
2024-07-19T18:09:53.078107785+08:00 Caused by: javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
at sun.security.ssl.Alert.createSSLException(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078118190+08:00 at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078159553+08:00 at sun.security.ssl.TransportContext.fatal(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078168424+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078174251+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078183672+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078189861+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078205962+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078225857+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078230762+08:00 at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078240324+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078246376+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078254218+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078259973+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078270917+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078281843+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078286938+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078292492+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078298099+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078303649+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078309140+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078320954+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078331554+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078337053+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078342792+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078347909+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078358359+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078372687+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078382613+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078412275+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078417884+08:00 at java.lang.Thread.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078427967+08:00 Caused by: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
2024-07-19T18:09:53.078433470+08:00 at sun.security.validator.PKIXValidator.doBuild(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078438565+08:00 at sun.security.validator.PKIXValidator.engineValidate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078443863+08:00 at sun.security.validator.Validator.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078448531+08:00 at sun.security.ssl.X509TrustManagerImpl.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078454065+08:00 at sun.security.ssl.X509TrustManagerImpl.checkTrusted(Unknown Source) ~[?:?]
at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078466196+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078471895+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078476551+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078481467+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078486861+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078491921+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078503380+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078508526+08:00 at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078513537+08:00 at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078519299+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078524490+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078529575+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078534914+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078540240+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078545907+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078559058+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078564544+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078569392+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078574369+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connecti
on.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078579387+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078589210+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078599447+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078604703+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078609737+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078630030+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078635586+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078640783+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078645993+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078651580+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078656433+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078661571+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078666939+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown So
urce) ~[?:?]
2024-07-19T18:09:53.078671900+08:00 at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
at sun.security.provider.certpath.SunCertPathBuilder.build(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078687366+08:00 at sun.security.provider.certpath.SunCertPathBuilder.engineBuild(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078712458+08:00 at java.security.cert.CertPathBuilder.build(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078718088+08:00 at sun.security.validator.PKIXValidator.doBuild(Unknown Source) ~[?:?]
at sun.security.validator.PKIXValidator.engineValidate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078728675+08:00 at sun.security.validator.Validator.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078733823+08:00 at sun.security.ssl.X509TrustManagerImpl.validate(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078739313+08:00 at sun.security.ssl.X509TrustManagerImpl.checkTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078744444+08:00 at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078749471+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078754075+08:00 at sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(Unknown Source) ~[?:?]
at sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078763698+08:00 at sun.security.ssl.SSLHandshake.consume(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078768534+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078773520+08:00 at sun.security.ssl.HandshakeContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078778702+08:00 at sun.security.ssl.TransportContext.dispatch(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078783640+08:00 at sun.security.ssl.SSLTransport.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078788765+08:00 at sun.security.ssl.SSLSocketImpl.decode(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078793762+08:00 at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(Unknown Source) ~[?:?]
at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078804147+08:00 at sun.security.ssl.SSLSocketImpl.startHandshake(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078809211+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:336) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:300) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078819071+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:185) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078823927+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.java:224) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078829259+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.java:108) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078834737+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078839517+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.Transmitter.newExchange(Transmitter.java:169) ~[flink-dist-1.19.1.jar:1.19.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:41) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078875873+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078882881+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078896255+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078901858+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078907635+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078912557+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078917945+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078923929+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078928794+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078934020+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java
:117) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078939459+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078944763+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:172) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078950104+08:00 at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) ~[flink-dist-1.19.1.jar:1.19.1]
2024-07-19T18:09:53.078955366+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
2024-07-19T18:09:53.078966269+08:00 at java.lang.Thread.run(Unknown Source) ~[?:?]
I submited a FlinkSQL project which receive data from kafka and write print table. It works.
I submited a FlinkSQL project which receive data from kafka and write hdfs table. It doesn't work and there are the same errors as the issue in the jobmanager pod log.
Search before asking
Java Version
JDK 11
Scala Version
2.12.x
StreamPark Version
2.1.4
Flink Version
1.19.1
deploy mode
kubernetes-application
What happened
The pod keeps rebooting.
Error Exception
Screenshots
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: