Skip to content

Commit

Permalink
Exit removed
Browse files Browse the repository at this point in the history
  • Loading branch information
mvrpl committed Mar 25, 2017
1 parent c08fedf commit 81c9a94
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions src/main/scala/shipper.scala
View file
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,6 @@ class Loader {
Row.fromSeq(list)
})
val dataFrame = spark.makeDF(rowsRDD, schema)
dataFrame.show()
System.exit(0)
if (configs.TARGET.ACTION.toStr.toLowerCase == "update"){
val targetTable = configs.TARGET.HIVE_TABLE.toStr
val targetDF = spark.hiveContext.sql(s"select * from $targetTable").toDF
Expand Down

0 comments on commit 81c9a94

Please sign in to comment.