Skip to content
Permalink
Browse files
Fix npe in spark-doris-connector when query is complex (#2503)
  • Loading branch information
vinson0526 authored and imay committed Dec 19, 2019
1 parent b53dc00 commit 5d3f6372c462cea030a3172e040843389e7e4236
Showing 1 changed file with 1 addition and 1 deletion.
@@ -101,7 +101,7 @@ class ScalaValueReader(partition: PartitionDefinition, settings: Settings) {
* @return true if hax next value
*/
def hasNext: Boolean = {
if ((rowBatch == null || !rowBatch.hasNext) && !eos) {
if (!eos && (rowBatch == null || !rowBatch.hasNext)) {
if (rowBatch != null) {
offset += rowBatch.getReadRowCount
rowBatch.close

0 comments on commit 5d3f637

Please sign in to comment.