Remove SimpleDoFnRunner timestamp check

kennknowles · kennknowles · commit 2cd51f5001b2 · 2025-11-17T10:44:49.000-05:00
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java
@@ -459,7 +459,6 @@ public <T> void outputWindowedValue(
           .setPaneInfo(paneInfo)
           .setReceiver(
               wv -> {
-                checkTimestamp(elem.getTimestamp(), wv.getTimestamp());
                 SimpleDoFnRunner.this.outputWindowedValue(tag, wv);
               })
           .output();
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`	`}`