DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner

kennknowles · kennknowles · commit 716cd5fdce3f · 2025-11-14T13:48:36.000-05:00
diff --git a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java
@@ -1860,7 +1860,7 @@ public OutputBuilder<OutputT> builder(OutputT value) {
           .withValue(value)
           .setReceiver(
               windowedValue -> {
-                checkTimestamp(windowedValue.getTimestamp());
+                // checkTimestamp(windowedValue.getTimestamp());
                 outputTo(mainOutputConsumer, windowedValue);
               });
     }

Original file line number	Diff line number	Diff line change
`@@ -1860,7 +1860,7 @@ public OutputBuilder<OutputT> builder(OutputT value) {`
`1860`	`1860`	`.withValue(value)`
`1861`	`1861`	`.setReceiver(`
`1862`	`1862`	`windowedValue -> {`
`1863`		`- checkTimestamp(windowedValue.getTimestamp());`
	`1863`	`+ // checkTimestamp(windowedValue.getTimestamp());`
`1864`	`1864`	`outputTo(mainOutputConsumer, windowedValue);`
`1865`	`1865`	`});`
`1866`	`1866`	`}`