laraschmidt commented on a change in pull request #15540:
URL: https://github.com/apache/beam/pull/15540#discussion_r714359098
##########
File path:
runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java
##########
@@ -386,6 +388,89 @@ public void testInfiniteSkew() {
BoundedWindow.TIMESTAMP_MAX_VALUE));
}
+ /**
+ * Demonstrates that attempting to set a timer with an output timestamp
before the timestamp of
+ * the current element with zero {@link DoFn#getAllowedTimestampSkew()
allowed timestamp skew}
+ * throws.
+ */
+ @Test
+ public void testTimerBackwardsInTimeNoSkew() {
Review comment:
I added ValidatesRunner tests for both the timer case and the normal
DoFn case as additional tests. Unit tests still make sense for this specific
DoFn and the validates runner ones cannot check for the exact error without
being overly restrictive. This seems like the wrong place for tests that
validate a runner but it seems like that's standard practice in beam so I just
put them here.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
