[FLINK-24363] java.io.FileNotFoundException crashes the standalone session manager

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.14.0
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Francesco Guardiani
• Created: 23/Sep/21 09:50
• Updated: 23/Sep/21 10:53
• Resolved: 23/Sep/21 09:53

Description

When trying to execute a query reading from a table configure with the filesystem connector and a bad path, the session manager crashes and sql client query execution times out:

org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Could not start RpcEndpoint jobmanager_2.
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:629) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.Actor.aroundReceive(Actor.scala:537) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.Actor.aroundReceive$(Actor.scala:535) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.ActorCell.invoke(ActorCell.scala:548) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_292]
Caused by: org.apache.flink.runtime.jobmaster.JobMasterException: Could not start the JobMaster.
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:391) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   ... 20 more
Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to start the operator coordinators
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:90) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   ... 20 more
Caused by: org.apache.flink.util.FlinkRuntimeException: Could not enumerate file splits
   at org.apache.flink.connector.file.src.AbstractFileSource.createEnumerator(AbstractFileSource.java:144) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:124) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.applyCall(RecreateOnResetOperatorCoordinator.java:291) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.start(RecreateOnResetOperatorCoordinator.java:70) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:85) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   ... 20 more
Caused by: java.io.FileNotFoundException: File file:/home/slinkydeveloper/bad_path does not exist or the user running Flink ('slinkydeveloper') has insufficient permissions to access it.
   at org.apache.flink.core.fs.local.LocalFileSystem.getFileStatus(LocalFileSystem.java:106) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.connector.file.src.enumerate.NonSplittingRecursiveEnumerator.enumerateSplits(NonSplittingRecursiveEnumerator.java:83) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.connector.file.src.AbstractFileSource.createEnumerator(AbstractFileSource.java:142) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:124) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.applyCall(RecreateOnResetOperatorCoordinator.java:291) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.start(RecreateOnResetOperatorCoordinator.java:70) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:85) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   ... 20 more
2021-09-23 11:06:16,456 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Fatal error occurred in the cluster entrypoint.
org.apache.flink.util.FlinkException: JobMaster for job 000b59600909066d618bc32a2ea8ad96 failed.
   at org.apache.flink.runtime.dispatcher.Dispatcher.jobMasterFailed(Dispatcher.java:902) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.dispatcher.Dispatcher.jobManagerRunnerFailed(Dispatcher.java:473) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$runJob$3(Dispatcher.java:430) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836) ~[?:1.8.0_292]
   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811) ~[?:1.8.0_292]
   at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456) ~[?:1.8.0_292]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:455) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:455) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.Actor.aroundReceive(Actor.scala:537) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.Actor.aroundReceive$(Actor.scala:535) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.actor.ActorCell.invoke(ActorCell.scala:548) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_292]
   at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_292]
Caused by: org.apache.flink.runtime.jobmaster.JobMasterException: Could not start the JobMaster.
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:391) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   ... 13 more
Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to start the operator coordinators
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:90) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   ... 13 more
Caused by: org.apache.flink.util.FlinkRuntimeException: Could not enumerate file splits
   at org.apache.flink.connector.file.src.AbstractFileSource.createEnumerator(AbstractFileSource.java:144) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:124) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.applyCall(RecreateOnResetOperatorCoordinator.java:291) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.start(RecreateOnResetOperatorCoordinator.java:70) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:85) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   ... 13 more
Caused by: java.io.FileNotFoundException: File file:/home/slinkydeveloper/bad_path does not exist or the user running Flink ('slinkydeveloper') has insufficient permissions to access it.
   at org.apache.flink.core.fs.local.LocalFileSystem.getFileStatus(LocalFileSystem.java:106) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.connector.file.src.enumerate.NonSplittingRecursiveEnumerator.enumerateSplits(NonSplittingRecursiveEnumerator.java:83) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.connector.file.src.AbstractFileSource.createEnumerator(AbstractFileSource.java:142) ~[flink-table_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:124) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.applyCall(RecreateOnResetOperatorCoordinator.java:291) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.start(RecreateOnResetOperatorCoordinator.java:70) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:85) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:584) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:965) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:882) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:389) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:624) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:623) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185) ~[flink-rpc-akka_a0e54fcb-a903-4676-9e88-cac15e82c6ff.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]
   at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[?:?]
   at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.14.0.jar:1.14.0]
   ... 13 more

I think the right behaviour is that the sql client reports the bad path exception and the session daemon doesn't crash.

Issue Links

• duplicates: FLINK-24303 SourceCoordinator exception may fail Session Cluster