From 884f66d56de51b59b37ba9fc9c5a8829e99d4cd7 Mon Sep 17 00:00:00 2001
From: XuanYang-cn <xuan.yang@zilliz.com>
Date: Tue, 29 Dec 2020 14:10:22 +0800
Subject: [PATCH] Fix timesync start twice in master
Signed-off-by: XuanYang-cn <xuan.yang@zilliz.com>
---
internal/master/master.go | 6 ------
tests/python/requirements.txt | 2 +-
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/internal/master/master.go b/internal/master/master.go
index 14ef3eb48..d73d8f290 100644
--- a/internal/master/master.go
+++ b/internal/master/master.go
@@ -113,9 +113,6 @@ func CreateServer(ctx context.Context) (*Master, error) {
pulsarProxyStream.Start()
var proxyStream ms.MsgStream = pulsarProxyStream
proxyTimeTickBarrier := newSoftTimeTickBarrier(ctx, &proxyStream, Params.ProxyIDList, Params.SoftTimeTickBarrierInterval)
- if err := proxyTimeTickBarrier.Start(); err != nil {
- return nil, err
- }
tsMsgProducer.SetProxyTtBarrier(proxyTimeTickBarrier)
pulsarWriteStream := ms.NewPulsarMsgStream(ctx, 1024) //output stream
@@ -124,9 +121,6 @@ func CreateServer(ctx context.Context) (*Master, error) {
pulsarWriteStream.Start()
var writeStream ms.MsgStream = pulsarWriteStream
writeTimeTickBarrier := newHardTimeTickBarrier(ctx, &writeStream, Params.WriteNodeIDList)
- if err := writeTimeTickBarrier.Start(); err != nil {
- return nil, err
- }
tsMsgProducer.SetWriteNodeTtBarrier(writeTimeTickBarrier)
pulsarDDStream := ms.NewPulsarMsgStream(ctx, 1024) //input stream
diff --git a/tests/python/requirements.txt b/tests/python/requirements.txt
index 7494bcd3e..b004de973 100644
--- a/tests/python/requirements.txt
+++ b/tests/python/requirements.txt
@@ -4,5 +4,5 @@ numpy==1.18.1
pytest==5.3.4
pytest-cov==2.8.1
pytest-timeout==1.3.4
-pymilvus-distributed==0.0.6
+pymilvus-distributed==0.0.5
sklearn==0.0
--
GitLab