Skip to content

Commit

Permalink
fix SparkClientGenerator when reading file, wrong columns (vesoft-inc…
Browse files Browse the repository at this point in the history
…#2187)

Co-authored-by: knightjya <knightjya@localhost.localdomain>
Co-authored-by: yaphet <darion.wang@vesoft.com>
Co-authored-by: dangleptr <37216992+dangleptr@users.noreply.github.com>
  • Loading branch information
4 people authored Jul 17, 2020
1 parent 9d1acc5 commit b79e300
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -310,7 +310,7 @@ object SparkClientGenerator {
val values = (for {
property <- valueProperties if property.trim.length != 0
} yield extraValue(row, property)).mkString(",")
(row.getString(vertexIndex), values)
(String.valueOf(extraValue(row, vertex)), values)
}(Encoders.tuple(Encoders.STRING, Encoders.STRING))
.foreachPartition { iterator: Iterator[(String, String)] =>
val service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(1))
Expand Down

0 comments on commit b79e300

Please sign in to comment.