From 1c572e92ef8e782447b483a20c848e0e33a60a59 Mon Sep 17 00:00:00 2001 From: Ivan Bella <347158+ivakegg@users.noreply.github.com> Date: Tue, 30 Dec 2025 19:02:24 +0000 Subject: [PATCH 1/2] Log a message when hitting a key that would have failed previously --- .../main/java/timely/server/store/MetricAgeOffIterator.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/src/main/java/timely/server/store/MetricAgeOffIterator.java b/server/src/main/java/timely/server/store/MetricAgeOffIterator.java index f71abbc3..1ba9a8d8 100644 --- a/server/src/main/java/timely/server/store/MetricAgeOffIterator.java +++ b/server/src/main/java/timely/server/store/MetricAgeOffIterator.java @@ -138,6 +138,11 @@ private void handleNewMetricName(String metricName) { */ private byte[] ensureFollowing(byte[] topRow, byte[] newStart) { if (WritableComparator.compareBytes(topRow, 0, topRow.length, newStart, 0, newStart.length) >= 0) { + // log a message so that we can determine how ofter this happens. + StringBuilder builder = new StringBuilder().append("Found a row in which the timestamp significantly differs from the encoded time: "); + Key.appendPrintableString(topRow, 0, topRow.length, topRow.length, builder); + log.warn(builder.toString()); + byte[] followingRow = new byte[topRow.length + 1]; System.arraycopy(topRow, 0, followingRow, 0, topRow.length); followingRow[topRow.length] = (byte) 0x00; From cf522c0f9f01539c45ad4d6ca0911944445f268c Mon Sep 17 00:00:00 2001 From: Ivan Bella <347158+ivakegg@users.noreply.github.com> Date: Tue, 30 Dec 2025 19:59:05 +0000 Subject: [PATCH 2/2] spelling --- .../src/main/java/timely/server/store/MetricAgeOffIterator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/timely/server/store/MetricAgeOffIterator.java b/server/src/main/java/timely/server/store/MetricAgeOffIterator.java index 1ba9a8d8..8106b06d 100644 --- a/server/src/main/java/timely/server/store/MetricAgeOffIterator.java +++ b/server/src/main/java/timely/server/store/MetricAgeOffIterator.java @@ -138,7 +138,7 @@ private void handleNewMetricName(String metricName) { */ private byte[] ensureFollowing(byte[] topRow, byte[] newStart) { if (WritableComparator.compareBytes(topRow, 0, topRow.length, newStart, 0, newStart.length) >= 0) { - // log a message so that we can determine how ofter this happens. + // log a message so that we can determine how often this happens. StringBuilder builder = new StringBuilder().append("Found a row in which the timestamp significantly differs from the encoded time: "); Key.appendPrintableString(topRow, 0, topRow.length, topRow.length, builder); log.warn(builder.toString());