This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new e73e180c1c Fix misleading start offset in data loss log (#16030)
e73e180c1c is described below
commit e73e180c1ce6b689b0eb61f3b8bc70f71247d7f6
Author: Kartik Khare <[email protected]>
AuthorDate: Sat Jun 7 02:49:21 2025 +0530
Fix misleading start offset in data loss log (#16030)
---
.../pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
index 114f968a11..27406557fb 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
@@ -1082,7 +1082,7 @@ public class RealtimeSegmentDataManager extends
SegmentDataManager {
if (messageBatch.hasDataLoss()) {
_serverMetrics.setValueOfTableGauge(_tableStreamName,
ServerGauge.STREAM_DATA_LOSS, 1L);
String message = "Message loss detected in stream partition: " +
_partitionGroupId + " for table: "
- + _tableNameWithType + " startOffset: " + _startOffset + "
batchFirstOffset: "
+ + _tableNameWithType + " startOffset: " + _currentOffset + "
batchFirstOffset: "
+ messageBatch.getFirstMessageOffset();
_segmentLogger.error(message);
_realtimeTableDataManager.addSegmentError(_segmentNameStr, new
SegmentErrorInfo(now(), message, null));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
