diff --git a/docs/content.zh/docs/dev/table/functions/ptfs.md b/docs/content.zh/docs/dev/table/functions/ptfs.md index fc89ab76f6c35..3c0eb9fb7c13f 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 { TimeContext 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 0b392c56d1141..8957f36ea8828 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 { TimeContext 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 19e5bdee501dd..ed9d243d269d3 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 @@ * TimeContext 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();