Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-9937

Kubernetes(Minikube) Flink : cannot submit job in Flink UI with FLink 1.5.1

    XMLWordPrintableJSON

    Details

    • Type: Wish
    • Status: Resolved
    • Priority: Major
    • Resolution: Information Provided
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None

      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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Filichkin Aleksandr Filichkin
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: