[proxima-beam] tune log message in ExpandContext

datadrivencz · Nov 19, 2024 · 04012cf · 04012cf
1 parent 641db17
commit 04012cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/beam/core/src/main/java/cz/o2/proxima/beam/util/state/ExpandContext.java b/beam/core/src/main/java/cz/o2/proxima/beam/util/state/ExpandContext.java
@@ -999,7 +999,7 @@ private List<TimestampedValue<KV<K, V>>> processBuffer(
               ExceptionUtils.unchecked(() -> processElementMethod.invoke(doFn, processArgs));
             } else {
               // return back to buffer
-              log.debug("Returning element {} to flush buffer", kv);
+              log.debug("Returning element {} to flush buffer, maxTs {}", kv, maxTs);
               pushedBackElements.add(kv);
             }
           });