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

Fix split switching in HiveInputFormatPartitionReader

    XMLWordPrintableJSON

Details

    Description

      Due to a bug if HiveInputFormatPartitionReader has read all data from an input split, and switches to a next one in hasNext(), no data will be read from that new one, thus it will return an empty row. The problem is that the reachedEnd() function call "loads" the next row, which is not invoked in case of split switching, thus the row will be empty.
       

      Attachments

        Issue Links

          duplicates

          Bug - A problem which impairs or prevents the functions of the product. FLINK-22661 HiveInputFormatPartitionReader can return invalid data

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #15629

          Activity

            People

              Unassigned Unassigned
              mgergely Miklos Gergely
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: