From 512bdb5be838b6d34fc7c3d4208f679496a7607d Mon Sep 17 00:00:00 2001
From: Anqi <anqi.wang@vesoft.com>
Date: Wed, 17 Jul 2024 10:15:00 +0800
Subject: [PATCH] not allow to read data from follower

---
 .../nebula/connector/reader/NebulaReader.scala       | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/reader/NebulaReader.scala b/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/reader/NebulaReader.scala
index ad5e4dd..a2d6b76 100644
--- a/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/reader/NebulaReader.scala
+++ b/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/reader/NebulaReader.scala
@@ -183,7 +183,7 @@ trait NebulaReader {
                                                                   nebulaOptions.limit,
                                                                   0,
                                                                   Long.MaxValue,
-                                                                  true,
+                                                                  false,
                                                                   true)
               } else {
                 vertexResponseIterator =
@@ -194,7 +194,7 @@ trait NebulaReader {
                                            nebulaOptions.limit,
                                            0,
                                            Long.MaxValue,
-                                           true,
+                                           false,
                                            true)
               }
             } catch {
@@ -240,8 +240,8 @@ trait NebulaReader {
                                                               nebulaOptions.limit,
                                                               0L,
                                                               Long.MaxValue,
-                                                              true,
-                                                              true)
+                                                              false,
+                                                              false)
               } else {
                 edgeResponseIterator = storageClient.scanEdge(nebulaOptions.spaceName,
                                                               scanPartIterator.next(),
@@ -250,8 +250,8 @@ trait NebulaReader {
                                                               nebulaOptions.limit,
                                                               0,
                                                               Long.MaxValue,
-                                                              true,
-                                                              true)
+                                                              false,
+                                                              false)
               }
             } catch {
               case e: Exception =>