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 index 38c82db2f..4169a36f4 100644 --- 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>> 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); } });