(flink) branch master updated: [hotfix][docs] Correct registerOnTime reference in PTF documentation

[fhueske]

This is an automated email from the ASF dual-hosted git repository.

fhueske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0b2e08753e1 [hotfix][docs] Correct registerOnTime reference in PTF 
documentation
0b2e08753e1 is described below

commit 0b2e08753e1100545260f0484d9ad239600bc99d
Author: Mika Naylor <mnay...@confluent.io>
AuthorDate: Tue May 5 17:11:53 2026 +0200

    [hotfix][docs] Correct registerOnTime reference in PTF documentation
---
 docs/content.zh/docs/dev/table/functions/ptfs.md                        | 2 +-
 docs/content/docs/dev/table/functions/ptfs.md                           | 2 +-
 .../java/org/apache/flink/table/functions/ProcessTableFunction.java     | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/docs/content.zh/docs/dev/table/functions/ptfs.md 
b/docs/content.zh/docs/dev/table/functions/ptfs.md
index fc89ab76f6c..3c0eb9fb7c1 100644
--- a/docs/content.zh/docs/dev/table/functions/ptfs.md
+++ b/docs/content.zh/docs/dev/table/functions/ptfs.md
@@ -1006,7 +1006,7 @@ class TimerFunction extends ProcessTableFunction<String> {
     TimeContext<Instant> timeCtx = ctx.timeContext(Instant.class);
       if (memory.seen == null) {
         memory.seen = input.getField(0).toString();
-        timeCtx.registerOnTimer("timeout", timeCtx.time().plusSeconds(60));
+        timeCtx.registerOnTime("timeout", timeCtx.time().plusSeconds(60));
       } else {
         collect("Second event arrived for: " + memory.seen);
         ctx.clearAll();
diff --git a/docs/content/docs/dev/table/functions/ptfs.md 
b/docs/content/docs/dev/table/functions/ptfs.md
index 0b392c56d11..8957f36ea88 100644
--- a/docs/content/docs/dev/table/functions/ptfs.md
+++ b/docs/content/docs/dev/table/functions/ptfs.md
@@ -1007,7 +1007,7 @@ class TimerFunction extends ProcessTableFunction<String> {
     TimeContext<Instant> timeCtx = ctx.timeContext(Instant.class);
       if (memory.seen == null) {
         memory.seen = input.getField(0).toString();
-        timeCtx.registerOnTimer("timeout", timeCtx.time().plusSeconds(60));
+        timeCtx.registerOnTime("timeout", timeCtx.time().plusSeconds(60));
       } else {
         collect("Second event arrived for: " + memory.seen);
         ctx.clearAll();
diff --git 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java
 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java
index 19e5bdee501..ed9d243d269 100644
--- 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java
+++ 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java
@@ -390,7 +390,7 @@ import java.time.LocalDateTime;
  *     TimeContext<Instant> timeCtx = ctx.timeContext(Instant.class);
  *     if (memory.seen == null) {
  *       memory.seen = input.getField(0).toString();
- *       timeCtx.registerOnTimer("timeout", timeCtx.time().plusSeconds(60));
+ *       timeCtx.registerOnTime("timeout", timeCtx.time().plusSeconds(60));
  *     } else {
  *       collect("Second event arrived for: " + memory.seen);
  *       ctx.clearAll();