SEPURI-SAI-KRISHNA commented on code in PR #29345:
URL: https://github.com/apache/flink/pull/29345#discussion_r4284127597
##########
docs/content/docs/dev/table/functions/ptfs.md:
##########
@@ -2892,6 +2892,65 @@ void testAtomicOutputFunctionOutput() throws Exception {
{{< top >}}
+### Snapshotting and Restoring a Test
+
+`snapshot()` captures a test at a point in time: the state of every partition,
the pending and the
+fired timers, the watermark of every table argument, and the collected output.
Passing the snapshot
+to `ProcessTableFunctionTestHarness.restoreFromSnapshot()` creates a new
harness that continues from
+there, which lets several test cases share one setup instead of repeating it.
+
+A snapshot is isolated from the harness it was taken from, so processing
further elements, advancing
+a watermark or changing state afterwards does not change what it holds. It can
also be restored more
+than once, and the restored harnesses are independent of each other. Every
restore runs a fresh
Review Comment:
Fixed, and unconditional now that `functionOutput` is copied. Both language
files say state, timers, partition keys and collected output are all deep
copied.
--
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]
