in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java [363:366]
public boolean hasFinished() {
return messageQueue.isEmpty() && isDone && outstandingReadsRequests.get() >= 1
&& splitSize <= entriesProcessed;
}