milvus/pkg/mq
yihao.dai 3af0d91f80
fix: Fix panic due to failed to seek (#34229) (#34230)
Converting the same msgposition's vchannel to a pchannel multiple times
would result in an invalid pchannel, leading to seek failure and panic.
This PR:
1. Make a copy of msgposition in msgdispatcher.
2. Check if channel is already a pchannel, no further channel conversion
is performed.

issue: https://github.com/milvus-io/milvus/issues/34221

pr: https://github.com/milvus-io/milvus/pull/34229

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2024-07-01 16:08:12 +08:00
..
common enhance: move rocksmq from internal to pkg (#34165) 2024-06-26 13:36:05 +08:00
mqimpl/rocksmq enhance: improve check health (#34265) 2024-07-01 10:18:07 +08:00
msgdispatcher fix: Fix panic due to failed to seek (#34229) (#34230) 2024-07-01 16:08:12 +08:00
msgstream enhance: move rocksmq from internal to pkg (#34165) 2024-06-26 13:36:05 +08:00