diff --git a/internal/master/master.go b/internal/master/master.go index 14ef3eb48e35645a2d9aa8a10e5aedece5a3060a..d73d8f29070ab8a5df9a0619e94a533266e30a45 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 7494bcd3e3926dc47225e343e0bc926f4e0185c3..b004de973fef827470342b21768803da3734ef2e 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