fix index out of range

Signed-off-by: Yashash H L <[email protected]>
numaproj · Dec 4, 2023 · 760706f · 760706f
1 parent 5586bdb
commit 760706f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/watermark/publish/src_publisher.go b/pkg/watermark/publish/src_publisher.go
@@ -105,7 +105,7 @@ func (df *sourcePublish) PublishSourceWatermarks(readMessages []*isb.ReadMessage
 func (df *sourcePublish) PublishIdleWatermarks(wm time.Time, partitions []int32) {
 	for _, partitionId := range partitions {
 		publisher := df.loadSourceWatermarkPublisher(partitionId)
-		publisher.PublishIdleWatermark(wmb.Watermark(wm), nil, partitionId) // while publishing idle watermark at source, we don't care about the offset
+		publisher.PublishIdleWatermark(wmb.Watermark(wm), nil, 0) // while publishing idle watermark at source, we don't care about the offset
 	}
 }