[
https://issues.apache.org/jira/browse/FLINK-9937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Filichkin updated FLINK-9937:
---------------------------------------
Description:
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
was:
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
Then make kubctl port-forward<JOBMANGER POD NAME> 8081
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
> 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)
