not allow to read data from follower

vesoft-inc · Nov 5, 2024 · 512bdb5 · 512bdb5
1 parent 2926644
commit 512bdb5
Showing 1 changed file with 6 additions and 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
@@ -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 =>