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

Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

    XMLWordPrintableJSON

Details

    Description

      Caused by: java.io.IOException: Cannot access file system for checkpoint/savepoint path 'file://.'.
      at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.resolveCheckpointPointer(AbstractFsCheckpointStorage.java:233)
      at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.resolveCheckpoint(AbstractFsCheckpointStorage.java:110)
      at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.restoreSavepoint(CheckpointCoordinator.java:1332)
      at org.apache.flink.runtime.scheduler.SchedulerBase.tryRestoreExecutionGraphFromSavepoint(SchedulerBase.java:314)
      at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:247)
      at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:223)
      at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:118)
      at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:103)
      at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:281)
      at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:269)
      at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:98)
      at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:40)
      at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.<init>(JobManagerRunnerImpl.java:146)
      ... 10 more
      Caused by: java.io.IOException: Found local file path with authority '.' in path 'file://.'. Hint: Did you forget a slash? (correct path would be 'file:///.')
      at org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:441)
      at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:389)
      at org.apache.flink.core.fs.Path.getFileSystem(Path.java:298)
      at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.resolveCheckpointPointer(AbstractFsCheckpointStorage.java:230)
      ... 22 more

      The original log is here, https://dev.azure.com/rmetzger/Flink/_build/results?buildId=6073&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=2b7514ee-e706-5046-657b-3430666e7bd9

      There are some similar tickets about this case, but the stack here looks different.

      Attachments

        Issue Links

          Activity

            People

              yunta Yun Tang
              SleePy Biao Liu
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: