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

Error in code comment for SubtaskStateMapper.RANGE

    XMLWordPrintableJSON

Details

    Description

      The code comments for SubtaskStateMapper.RANGE are as follows:

       * <p>Example:<br>
       * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)<br>
       * new assignment: 0 -> [0;64]; 1 -> [64;128)<br>
       * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data from old subtask 0
       * + 2

      The correct code comment should be:

       

       * <p>Example:<br>
       * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)<br>
       * new assignment: 0 -> [0;64]; 1 -> [64;128)<br>
       * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data from old subtask 1
       * + 2

      subtask 1 should recovers data from old subtask 1 + 2,not from old subtask 0 + 2

       

      Attachments

        Issue Links

          Activity

            People

              ruanshubin Shubin Ruan
              ruanshubin Shubin Ruan
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: