boyuanzz commented on a change in pull request #13282:
URL: https://github.com/apache/beam/pull/13282#discussion_r520984675
##########
File path:
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java
##########
@@ -407,4 +408,13 @@ public double getTotalSize(double numRecords) {
return avgRecordSize.get() * numRecords / (1 + avgRecordGap.get());
}
}
+
+ private static Instant ensureTimestampWithinBounds(Instant timestamp) {
Review comment:
The MIN_TIMESTAMP produced in Dataflow is smaller than
`BoundedWindow.MIN_TIMESTAMP`.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
