Method StopKrpcBackend

be/src/runtime/data-stream-test.cc:633–635

  }

  void StopKrpcBackend() {
    exec_env_->rpc_mgr()->Shutdown();
  }

  void StartSender(TPartitionType::type partition_type = TPartitionType::UNPARTITIONED,
      int channel_buffer_size = 1024, bool reset_hash_seed = false,