[ https://issues.apache.org/jira/browse/FLINK-9937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555569#comment-16555569 ]
Aleksandr Filichkin commented on FLINK-9937: -------------------------------------------- The issue with jobmanage connectivity. Jobmanager docker image cannot connect to "flink-jobmanager" (${JOB_MANAGER_RPC_ADDRESS}) address. Just use afilichkin/k8s Docker instead of flink:latest I've fixed it by adding new host to jobmanager docker. You can see it in my github project https://github.com/Aleksandr-Filichkin/flink-k8s/tree/master > Kubernetes(Minikube) Flink : cannot submit job in Flink UI with FLink 1.5.1 > --------------------------------------------------------------------------- > > Key: FLINK-9937 > URL: https://issues.apache.org/jira/browse/FLINK-9937 > Project: Flink > Issue Type: Wish > Reporter: Aleksandr Filichkin > Priority: Major > > Hi, > I cannot submit Flink 1,5,1 job from UI on Kubernetes(minikube). > But it works perfect with Flink 1.4.2 > I've created Flink artifacts like this: > kubectl create -f jobmanager-deployment.yaml > kubectl create -f taskmanager-deployment.yaml > kubectl create -f jobmanager-service.yaml > From > https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/kubernetes.html > 10.102.96.227 is Job-Manager Kubernetes service ip > Log: > 018-07-24 13:52:06,141 ERROR > org.apache.flink.runtime.webmonitor.handlers.JarRunHandler - Exception > occurred in REST handler. > org.apache.flink.runtime.rest.handler.RestHandlerException: > org.apache.flink.util.FlinkException: Could not upload job jar files. > at > org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$3(JarRunHandler.java:141) > at > java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870) > at > java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852) > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) > at > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > Caused by: java.util.concurrent.CompletionException: > org.apache.flink.util.FlinkException: Could not upload job jar files. > at > org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:121) > at > java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105) > at > java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070) > ... 8 more > Caused by: org.apache.flink.util.FlinkException: Could not upload job jar > files. > ... 11 more > Caused by: java.io.IOException: Could not connect to BlobServer at address > flink-jobmanager/10.102.96.227:6124 > at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:124) > at > org.apache.flink.runtime.blob.BlobClient.uploadJarFiles(BlobClient.java:547) > at > org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:119) > ... 10 more > Caused by: java.net.ConnectException: Connection timed out (Connection timed > out) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) > at java.net.Socket.connect(Socket.java:589) > at java.net.Socket.connect(Socket.java:538) > at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:118) > ... 12 more -- This message was sent by Atlassian JIRA (v7.6.3#76005)