Zhen Ye
Zhen Ye
/assign @zhagnlu
Our msgstream implementation of pulsar use a named-subscription with exclusive option. So when concurrent create same subscription of pulsar consumer will report this error. Found that the `datanode-6-by-dev-rootcoord-dml_11_453764290321215082v0-false` subscription is...
Duplicate create found at milvus msgstream dispatcher. ``` 2024-11-08 11:16:00.468 [2024/11/08 03:16:00.468 +00:00] [INFO] [msgdispatcher/dispatcher.go:93] ["creating dispatcher..."] [pchannel=by-dev-rootcoord-dml_10] [subName=datanode-6-by-dev-rootcoord-dml_10_453764290321208660v0-true] [isMain=true] 2024-11-08 11:16:20.552 [2024/11/08 03:16:20.552 +00:00] [INFO] [msgdispatcher/dispatcher.go:93] ["creating dispatcher..."] [pchannel=by-dev-rootcoord-dml_10]...
There're two issues in milvus. 1. The `NewDataSyncService` operation is not Idempotent. Once the following operation is failed, channel that is regsitered into msgstream dispatcher can not be cleared (resource...
It seems that the bookie is OOMKilled. ``` mdpm-master-380-py-n-pulsarv3-bookie-2 42 OOMKilled ``` still working on it.
we limit 2GB memory for bookkeeper. But bookeeper default setup here. ``` -Xms4096m -Xmx4096m -XX:MaxDirectMemorySize=8192m ``` So OOM happens.
/assign @NicoYuan1986 It seems that it's fixed after modifying the configuration of bookie, please help to verify it. https://jenkins.milvus.io:18080/blue/organizations/jenkins/Milvus%20Nightly%20CI(new)/detail/master/383/pipeline /unassign
Schemachange is ddl, will acquire lock for rc. The broadcast operation will rely on the flusher of underlying wal on streamingnode. The flusher recovery will use the `GetChannelRecoveryInfo`, `GetChannelRecoveryInfo` will...
should be fixed by #43235
/assign @NicoYuan1986 please help to verify it