feast-dev
diff --git a/‎spark/ingestion/src/main/scala/feast/ingestion/sources/bq/BigQueryReader.scala‎
Lines changed: 1 addition & 1 deletion b/‎spark/ingestion/src/main/scala/feast/ingestion/sources/bq/BigQueryReader.scala‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎spark/ingestion/src/main/scala/feast/ingestion/sources/file/FileReader.scala‎
Lines changed: 1 addition & 1 deletion b/‎spark/ingestion/src/main/scala/feast/ingestion/sources/file/FileReader.scala‎
Lines changed: 1 addition & 1 deletion
@@ -46,6 +46,6 @@ object BigQueryReader {
     reader
       .load(s"${source.project}.${source.dataset}.${source.table}")
       .filter(col(source.eventTimestampColumn) >= new Timestamp(start.getMillis))
-      .filter(col(source.eventTimestampColumn) <= new Timestamp(end.getMillis))
+      .filter(col(source.eventTimestampColumn) < new Timestamp(end.getMillis))
   }
 }
@@ -33,6 +33,6 @@ object FileReader {
     sqlContext.read
       .parquet(source.path)
       .filter(col(source.eventTimestampColumn) >= new Timestamp(start.getMillis))
-      .filter(col(source.eventTimestampColumn) <= new Timestamp(end.getMillis))
+      .filter(col(source.eventTimestampColumn) < new Timestamp(end.getMillis))
   }
 }
Original file line number	Diff line number	Diff line change
`@@ -46,6 +46,6 @@ object BigQueryReader {`
`46`	`46`	`reader`
`47`	`47`	`.load(s"${source.project}.${source.dataset}.${source.table}")`
`48`	`48`	`.filter(col(source.eventTimestampColumn) >= new Timestamp(start.getMillis))`
`49`		`- .filter(col(source.eventTimestampColumn) <= new Timestamp(end.getMillis))`
	`49`	`+ .filter(col(source.eventTimestampColumn) < new Timestamp(end.getMillis))`
`50`	`50`	`}`
`51`	`51`	`}`
Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,6 @@ object FileReader {`
`33`	`33`	`sqlContext.read`
`34`	`34`	`.parquet(source.path)`
`35`	`35`	`.filter(col(source.eventTimestampColumn) >= new Timestamp(start.getMillis))`
`36`		`- .filter(col(source.eventTimestampColumn) <= new Timestamp(end.getMillis))`
	`36`	`+ .filter(col(source.eventTimestampColumn) < new Timestamp(end.getMillis))`
`37`	`37`	`}`
`38`	`38`	`}`