Skip to content

Commit

Permalink
Revert "Add startingTimestamp option (#22)"
Browse files Browse the repository at this point in the history
This reverts commit a4eb13c.
  • Loading branch information
ChewingGlass committed Jan 8, 2024
1 parent a4eb13c commit 33de6c6
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
2 changes: 1 addition & 1 deletion spark-streaming-sql/build.sbt
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
scalaVersion := "2.13.8"
name := "spark-streaming-sql"
organization := "helium"
version := "1.0.3"
version := "1.0.2"

val sparkVersion = "3.4.0"

Expand Down
1 change: 0 additions & 1 deletion spark-streaming-sql/src/main/scala/Main.scala
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,6 @@ object Main extends App {
.outputMode("append")
.partitionBy(sys.env.get("PARTITION_BY").get.split(","): _*)
.option("checkpointLocation", sys.env.get("CHECKPOINT").get)
.option("startingTimestamp", sys.env.getOrElse("STARTING_TIMESTAMP", "2017-01-01"))
.trigger(trigger)
.start(sys.env.get("OUTPUT").get)
.awaitTermination()
Expand Down

0 comments on commit 33de6c6

Please sign in to comment.