From 086d7849ec47e17c6db1d83c61854a83f58029a2 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 29 Sep 2020 23:05:35 +0800 Subject: [PATCH] Fix conflict when choosing pulsar producer Signed-off-by: xige-16 --- proxy/src/message_client/ClientV2.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/proxy/src/message_client/ClientV2.cpp b/proxy/src/message_client/ClientV2.cpp index a82c198df2..ecab3591fc 100644 --- a/proxy/src/message_client/ClientV2.cpp +++ b/proxy/src/message_client/ClientV2.cpp @@ -192,7 +192,9 @@ Status MsgClientV2::SendMutMessage(const milvus::grpc::InsertParam &request, mut_msg.set_collection_name(request.collection_name()); mut_msg.set_partition_tag(request.partition_tag()); uint64_t uid = request.entity_id_array(i); - auto channel_id = makeHash(&uid, sizeof(uint64_t)) % topic_num; + // auto channel_id = makeHash(&uid, sizeof(uint64_t)) % topic_num; + //TODO:: don't prove the correction + auto channel_id = this_thread; try { mut_msg.set_segment_id(segment_id(request.collection_name(), channel_id, timestamp)); mut_msg.mutable_rows_data()->CopyFrom(request.rows_data(i));