(flink) branch master updated: [hotfix] Log whether interruptible timers are enabled

[roman]

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

roman 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 b1831be82be [hotfix] Log whether interruptible timers are enabled
b1831be82be is described below

commit b1831be82be4cd5efb68f0608a7b9146e274723c
Author: Roman Khachatryan <khachatryan.ro...@gmail.com>
AuthorDate: Tue Jan 13 15:08:21 2026 +0100

    [hotfix] Log whether interruptible timers are enabled
---
 .../org/apache/flink/streaming/api/operators/AbstractStreamOperator.java | 1 +
 .../apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java   | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
index 95348ac06cb..156d306449b 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -393,6 +393,7 @@ public abstract class AbstractStreamOperator<OUT>
         if (useInterruptibleTimers()
                 && areInterruptibleTimersConfigured()
                 && getTimeServiceManager().isPresent()) {
+            LOG.info("Interruptible timers enabled for {}", 
getClass().getSimpleName());
             this.watermarkProcessor =
                     new MailboxWatermarkProcessor(
                             output, mailboxExecutor, 
getTimeServiceManager().get());
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java
 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java
index f8e2762cff0..abd79021863 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java
@@ -247,6 +247,7 @@ public abstract class AbstractStreamOperatorV2<OUT>
         if (useInterruptibleTimers()
                 && areInterruptibleTimersConfigured()
                 && getTimeServiceManager().isPresent()) {
+            LOG.info("Interruptible timers enabled for {}", 
getClass().getSimpleName());
             watermarkProcessor =
                     new MailboxWatermarkProcessor(
                             output, mailboxExecutor, 
getTimeServiceManager().get());