diff --git a/spark-streaming-sql/build.sbt b/spark-streaming-sql/build.sbt
index 6d2dd5b..a244e93 100644
--- a/spark-streaming-sql/build.sbt
+++ b/spark-streaming-sql/build.sbt
@@ -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"
 
diff --git a/spark-streaming-sql/src/main/scala/Main.scala b/spark-streaming-sql/src/main/scala/Main.scala
index 8b51051..f4c54b2 100644
--- a/spark-streaming-sql/src/main/scala/Main.scala
+++ b/spark-streaming-sql/src/main/scala/Main.scala
@@ -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()