fix test

vesoft-inc · Jan 5, 2022 · 1c68cda · 1c68cda
1 parent 83c5f28
commit 1c68cda
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/...ge_spark_2.2/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala b/...ge_spark_2.2/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala
@@ -67,7 +67,7 @@ class EdgeProcessorSuite {
                         "col14")
 
   val processClazz =
-    new EdgeProcessor(data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
+    new EdgeProcessor(null, data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isEdgeValidSuite(): Unit = {
     val stringIdValue = List("Bob", "Tom")

diff --git a/...park_2.2/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala b/...park_2.2/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala
@@ -67,7 +67,7 @@ class VerticesProcessorSuite {
                         "col14")
 
   val processClazz =
-    new VerticesProcessor(data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
+    new VerticesProcessor(null, data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isVertexValidSuite(): Unit = {
     val stringIdValue      = List("Bob")

diff --git a/...ge_spark_2.4/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala b/...ge_spark_2.4/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala
@@ -68,7 +68,7 @@ class EdgeProcessorSuite {
                         "col14")
 
   val processClazz =
-    new EdgeProcessor(data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
+    new EdgeProcessor(null, data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isEdgeValidSuite(): Unit = {
     val stringIdValue = List("Bob", "Tom")

diff --git a/...park_2.4/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala b/...park_2.4/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala
@@ -68,7 +68,7 @@ class VerticesProcessorSuite {
                         "col14")
 
   val processClazz =
-    new VerticesProcessor(data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
+    new VerticesProcessor(null, data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isVertexValidSuite(): Unit = {
     val stringIdValue      = List("Bob")

diff --git a/...ge_spark_3.0/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala b/...ge_spark_3.0/src/test/scala/com/vesoft/nebula/exchange/processor/EdgeProcessorSuite.scala
@@ -67,7 +67,7 @@ class EdgeProcessorSuite {
                         "col14")
 
   val processClazz =
-    new EdgeProcessor(data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
+    new EdgeProcessor(null, data, edgeConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isEdgeValidSuite(): Unit = {
     val stringIdValue = List("Bob", "Tom")

diff --git a/...park_3.0/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala b/...park_3.0/src/test/scala/com/vesoft/nebula/exchange/processor/VerticesProcessorSuite.scala
@@ -67,7 +67,7 @@ class VerticesProcessorSuite {
                         "col14")
 
   val processClazz =
-    new VerticesProcessor(data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
+    new VerticesProcessor(null, data, tagConfig, fieldKeys, nebulaKeys, config, null, null)
   @Test
   def isVertexValidSuite(): Unit = {
     val stringIdValue      = List("Bob")