flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9937) Kubernetes(Minikube) Flink : cannot submit job in Flink UI with FLink 1.5.1
Date Tue, 24 Jul 2018 12:15:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-9937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554176#comment-16554176
] 

Chesnay Schepler commented on FLINK-9937:
-----------------------------------------

Is this the only exception in the JobManager logs? Could you run it again with DEBUG logging
enabled?

The exception doesn't quite make sense considering the issue description.
According to the exception the UI attempted to retrieve information about a job.
This can only happen if the job was properly submitted, as otherwise no ID is returned.

> 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
> Then make kubctl port-forward<JOBMANGER POD NAME> 8081
> Log:
>  2018-07-24 11:47:17,730 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
 - Registering TaskManager 407eac4f10f975b1334c89bd4896412b under 0a53ef353916bd20e7869e32d9419338
at the SlotManager.
> 2018-07-24 11:47:20,334 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
 - Registering TaskManager c750cbfadbf71b9de7fba2344760a758 under b9b04d04b79ee64996d6e5c2781b19d1
at the SlotManager.
> 2018-07-24 11:52:49,707 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler
  - Exception occurred in REST handler.
> org.apache.flink.runtime.rest.NotFoundException: Job 6bc30e7df8f3410c110150fc0c90ce69
not found
> 	at org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$1(AbstractExecutionGraphHandler.java:90)
> 	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.completeExceptionally(CompletableFuture.java:1977)
> 	at org.apache.flink.runtime.rest.handler.legacy.ExecutionGraphCache.lambda$getExecutionGraph$0(ExecutionGraphCache.java:133)
> 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
> 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
> 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
> 	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
> 	at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:811)
> 	at akka.dispatch.OnComplete.internal(Future.scala:258)
> 	at akka.dispatch.OnComplete.internal(Future.scala:256)
> 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:186)
> 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:183)
> 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message