diff --git a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/reader/DataReader.scala b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/reader/DataReader.scala index c2392f5..872e834 100644 --- a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/reader/DataReader.scala +++ b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/reader/DataReader.scala @@ -204,8 +204,6 @@ final class HiveReader extends DataReader { data.repartition(partitionNum) } - data.show(3) - data } } diff --git a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/writer/AlgoWriter.scala b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/writer/AlgoWriter.scala index 31f07e0..3fcb8ce 100644 --- a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/writer/AlgoWriter.scala +++ b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/writer/AlgoWriter.scala @@ -95,8 +95,6 @@ final class HiveWriter extends AlgoWriter { spark.sql(createTableStatement) } - println(s"Save to hive:${config.dbTableName}, saveMode:${saveMode}") - _data.show(3) _data.write.mode(saveMode).insertInto(config.dbTableName) }