diff --git a/collector-agent/agent/GrpcAgent.go b/collector-agent/agent/GrpcAgent.go index fe0b8699..c03d920d 100644 --- a/collector-agent/agent/GrpcAgent.go +++ b/collector-agent/agent/GrpcAgent.go @@ -403,7 +403,7 @@ func (agent *GrpcAgent) collectorActiveThreadCount(conn *grpc.ClientConn, respon defer wg.Done() client := v1.NewProfilerCommandServiceClient(conn) - ctx, _ := common.BuildMdContextWithTimeout(agent.config.GrpcConTextTimeOut, agent.pingMd) + ctx, _ := common.BuildMdContextWithTimeout(-1, agent.pingMd) stream_client, err := client.CommandStreamActiveThreadCount(ctx) if err != nil {