You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Miklos Gergely (Jira)" <ji...@apache.org> on 2021/04/15 10:50:00 UTC

[jira] [Created] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader

Miklos Gergely created FLINK-22291:
--------------------------------------

             Summary: Fix split switching in HiveInputFormatPartitionReader
                 Key: FLINK-22291
                 URL: https://issues.apache.org/jira/browse/FLINK-22291
             Project: Flink
          Issue Type: Bug
            Reporter: Miklos Gergely


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.
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)