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

Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

    XMLWordPrintableJSON

Details

    • Fixes issue where the failover cause it not listed in the exception history but as a root cause. That could have happened if the failure occurred during JobMaster initialization.

    Description

      Currently we are using flink version 1.13.2 and as per the flink documentation we should get all exceptions through exceptions api in exceptionHistory tag. While running few scenarios we observed that the below two exceptions are not coming in exceptionHistory tag but are coming in root-exception tag.

      Exception 1 - caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: java.io.FileNotFoundException: Cannot find checkpoint or savepoint file/directory 'C:\Users\abc\Documents\checkpoints\a737088e21206281db87f6492bcba074' on file system 'file'.

      Exception 2 - Caused by: java.lang.IllegalStateException: Failed to rollback to checkpoint/savepoint file:/mnt/c/Users/abc/Documents/checkpoints/a737088e21206281db87f6492bcba074/chk-144.

      Please find the attachment for the logs of above exceptions.

      Attachments

        Activity

          People

            mapohl Matthias Pohl
            mahi.29agarwal Mahima
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: