From 37cdf079a7dcd1c440ad848dcfda48cb16a4120c Mon Sep 17 00:00:00 2001
From: ClownXC <chen3494269@163.com>
Date: Tue, 30 Apr 2024 09:41:20 +0800
Subject: [PATCH] eos set false

---
 .../starrocks/client/source/StarRocksBeReadClient.java          | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java
index b199c6cc137..bf627d4887e 100644
--- a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java
+++ b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java
@@ -91,6 +91,7 @@ public StarRocksBeReadClient(String beNodeInfo, SourceConfig sourceConfig) {
     }
 
     public void openScanner(QueryPartition partition, SeaTunnelRowType seaTunnelRowType) {
+        eos.set(false);
         this.seaTunnelRowType = seaTunnelRowType;
         Set<Long> tabletIds = partition.getTabletIds();
         TScanOpenParams params = new TScanOpenParams();
@@ -139,6 +140,7 @@ public void openScanner(QueryPartition partition, SeaTunnelRowType seaTunnelRowT
     public boolean hasNext() {
         boolean hasNext = false;
         // Arrow data was acquired synchronously during the iterative process
+        System.out.println("eos.get(): " + eos.get());
         if (!eos.get() && (rowBatch == null || !rowBatch.hasNext())) {
             if (rowBatch != null) {
                 readerOffset += rowBatch.getReadRowCount();