search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.85k stars 990 forks source link

[Bug] Deploying in k8s, reporting errors #3894

Open zuilikanhua opened 1 month ago

zuilikanhua commented 1 month ago

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

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) ~[?:?]

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

xiamuyingu commented 2 weeks ago

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.