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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)