From 34009b30ce50a86cb2a8745909a3f19b6d3dbf31 Mon Sep 17 00:00:00 2001 From: jiahao_liu Date: Wed, 29 Jul 2020 10:01:18 +0800 Subject: [PATCH] fix double quote in index --- .../nebula/tools/generator/v2/SparkClientGenerator.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/nebula/tools/generator/v2/SparkClientGenerator.scala b/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/nebula/tools/generator/v2/SparkClientGenerator.scala index fae402eed19..47b060afbda 100644 --- a/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/nebula/tools/generator/v2/SparkClientGenerator.scala +++ b/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/nebula/tools/generator/v2/SparkClientGenerator.scala @@ -51,7 +51,7 @@ object SparkClientGenerator { private[this] val BATCH_INSERT_TEMPLATE = "INSERT %s %s(%s) VALUES %s" private[this] val INSERT_VALUE_TEMPLATE = "%s: (%s)" - private[this] val INSERT_VALUE_TEMPLATE_WITH_POLICY = "%s(\"%s\"): (%s)" + private[this] val INSERT_VALUE_TEMPLATE_WITH_POLICY = "%s(%s): (%s)" private[this] val ENDPOINT_TEMPLATE = "%s(\"%s\")" private[this] val EDGE_VALUE_WITHOUT_RANKING_TEMPLATE = "%s->%s: (%s)" private[this] val EDGE_VALUE_WITHOUT_RANKING_TEMPLATE_WITH_POLICY = "%s->%s: (%s)" @@ -297,7 +297,6 @@ object SparkClientGenerator { fields.asScala.keys.toList } - val vertexIndex = sourceProperties.indexOf(vertex) val nebulaProperties = properties.mkString(",") val data = createDataSource(spark, pathOpt, tagConfig)