change spark context

96afd439 · 高雅喆 · 642514a4 · 96afd439 · 96afd439
Commit 96afd439 authored 6 years ago by 高雅喆
Show whitespace changes
Inline Side-by-side

Showing with 1 addition and 2 deletions

GmeiConfig.scala eda/node2vec/src/main/scala/com/gmei/GmeiConfig.scala +0 -1

Main.scala eda/node2vec/src/main/scala/com/gmei/Main.scala +1 -1

No files found.
--- a/eda/node2vec/src/main/scala/com/gmei/GmeiConfig.scala
+++ b/eda/node2vec/src/main/scala/com/gmei/GmeiConfig.scala
@@ -78,7 +78,6 @@ object GmeiConfig extends Serializable {

  def writeToJDBCTable(df: DataFrame, table: String, saveMode: SaveMode): Unit = {
    val jdbcuri = this.config.getString("tidb.jdbcuri")
-    println(jdbcuri, table)
    writeToJDBCTable(jdbcuri, df, table, saveMode)
  }


--- a/eda/node2vec/src/main/scala/com/gmei/Main.scala
+++ b/eda/node2vec/src/main/scala/com/gmei/Main.scala
@@ -232,7 +232,7 @@ object Main {
      println("done3")


-      context.stop()
+      sc.stop()

    }
  } getOrElse {