This is an automated email from the ASF dual-hosted git repository. yashmayya pushed a commit to branch release-1.5.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git
commit a2c84e823f54d263345708ea0e42984797c11ca4 Author: leiguo <[email protected]> AuthorDate: Wed Mar 25 17:59:48 2026 +0800 Fix incorrect stream partition id for multi-stream realtime consumption (#17953) Co-authored-by: leguo2 <[email protected]> --- .../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 37c9511d2bb..3429a6ad98d 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 @@ -1729,7 +1729,7 @@ public class RealtimeSegmentDataManager extends SegmentDataManager { String streamTopic = _streamConfig.getTopicName(); _segmentNameStr = _segmentZKMetadata.getSegmentName(); _partitionGroupConsumptionStatus = - new PartitionGroupConsumptionStatus(_partitionGroupId, llcSegmentName.getSequenceNumber(), + new PartitionGroupConsumptionStatus(_partitionGroupId, _streamPartitionId, llcSegmentName.getSequenceNumber(), _streamPartitionMsgOffsetFactory.create(_segmentZKMetadata.getStartOffset()), _segmentZKMetadata.getEndOffset() == null ? null : _streamPartitionMsgOffsetFactory.create(_segmentZKMetadata.getEndOffset()), --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
