fix missing operateType

vesoft-inc · Nov 23, 2023 · 1d9735a · 1d9735a
1 parent 1324c80
commit 1d9735a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/package.scala b/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/package.scala
@@ -123,6 +123,7 @@ package object connector {
       val dfReader = reader
         .format(classOf[NebulaDataSource].getName)
         .option(NebulaOptions.TYPE, DataTypeEnum.EDGE.toString)
+        .option(NebulaOptions.OPERATE_TYPE, OperaType.READ.toString)
         .option(NebulaOptions.SPACE_NAME, readConfig.getSpace)
         .option(NebulaOptions.LABEL, readConfig.getLabel)
         .option(NebulaOptions.RETURN_COLS, readConfig.getReturnCols.mkString(","))