diff --git a/internal/distributed/proxy/service.go b/internal/distributed/proxy/service.go index a35ea9c604..0bc66157c8 100644 --- a/internal/distributed/proxy/service.go +++ b/internal/distributed/proxy/service.go @@ -174,10 +174,6 @@ func (s *Server) startExternalGrpc(grpcPort int, errChan chan error) { proxy.UnaryServerInterceptor(proxy.PrivilegeInterceptor), logutil.UnaryTraceLoggerInterceptor, )), - grpc.StreamInterceptor(grpc_middleware.ChainStreamServer( - ot.StreamServerInterceptor(opts...), - grpc_auth.StreamServerInterceptor(proxy.AuthenticationInterceptor), - logutil.StreamTraceLoggerInterceptor)), } if Params.TLSMode == 1 { @@ -263,14 +259,8 @@ func (s *Server) startInternalGrpc(grpcPort int, errChan chan error) { grpc.MaxSendMsgSize(Params.ServerMaxSendSize), grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer( ot.UnaryServerInterceptor(opts...), - grpc_auth.UnaryServerInterceptor(proxy.AuthenticationInterceptor), logutil.UnaryTraceLoggerInterceptor, )), - grpc.StreamInterceptor(grpc_middleware.ChainStreamServer( - ot.StreamServerInterceptor(opts...), - grpc_auth.StreamServerInterceptor(proxy.AuthenticationInterceptor), - logutil.StreamTraceLoggerInterceptor, - )), ) proxypb.RegisterProxyServer(s.grpcInternalServer, s) milvuspb.RegisterMilvusServiceServer(s.grpcInternalServer, s)