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

Potentially NPE of preview plan functionality

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Not A Problem
    • 1.10.0
    • None
    • Command Line Client
    • None

    Description

      PackagedProgram#getPreviewPlan contains code as below

      if (isUsingProgramEntryPoint()) {
          previewPlan = Optimizer.createPreOptimizedPlan(getPlan());
      } else if (isUsingInteractiveMode()) {
          // ...
          getPlan().getJobId();
          // ....
      }
      

      when the latter #getPlan executed, it will finally execute program.getPlan(options) where program equals null.

      To solve this problem, we can replace getPlan with env.getPlan. Where env is an instance of PreviewPlanEnvironment

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              tison Zili Chen
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: