使用mindspore训练网络时内存问题
收藏回复举报
使用mindspore训练网络时内存问题
t('forum.solved') 已解决
新人帖
发表于2024-03-03 10:58:56
0 查看

我们将一个原先使用pytorch网络的模型迁移到mindspore环境下训练,产生了内存过度增长的问题。

在torch下训练模型,调用任务管理器,内存占用基本在较小范围内变化。 迁移到mindspore下训练时,内存占用会以每秒约20M的速度迅速攀升,直到主机内存溢出。

我们猜测在模型迁移时有实现方式不一致的映射,导致训练时内存空间没有被释放,但没有找到对应的问题所在

模型迁移时修改的主要内容如下

1.训练过程 true 训练过程代码较多,概括为:参考了文档中对梯度反传的不同计算过程,采用文档方法编写训练过程

1)mindspore

for _ in range(self.K_epochs):
    for index in CustomSampler(self.batch_size, self.mini_batch_size):
        grad_fn1 = mindspore.value_and_grad(forward_fn1, None, self.optimizer_actor.parameters)
        actor_loss, grads1 = grad_fn1(s[index], a[index], a_logprob[index], adv[index])
        if self.use_grad_clip:  # Trick 7: Gradient clip
            grads1 = ops.clip_by_norm(grads1, 0.5)
        self.optimizer_actor(grads1)


        # Update critic
        grad_fn2 = mindspore.value_and_grad(forward_fn2, None, self.optimizer_critic.parameters)
        critic_loss, grads2 = grad_fn2(s[index], a[index], v_target[index])
        self.critic_loss.append(critic_loss.item())
        if self.use_grad_clip:  # Trick 7: Gradient clip
            grads2 = ops.clip_by_norm(grads2, 0.5)
        self.optimizer_critic(grads2)

2)torch

for _ in range(self.K_epochs):

    for index in BatchSampler(SubsetRandomSampler(range(self.batch_size)), self.mini_batch_size, False):
        dist_now = self.actor.get_dist(s[index])
        dist_entropy = dist_now.entropy().sum(1, keepdim=True)
        a_logprob_now = dist_now.log_prob(a[index])
        # a/b=exp(log(a)-log(b))  In multi-dimensional continuous action space,we need to sum up the log_prob
        ratios = torch.exp(a_logprob_now.sum(1, keepdim=True) - a_logprob[index].sum(1,                                                                                        keepdim=True))  # shape(mini_batch_size X 1)

        surr1 = ratios * adv[index]  # Only calculate the gradient of 'a_logprob_now' in ratios
        surr2 = torch.clamp(ratios, 1 - self.epsilon, 1 + self.epsilon) * adv[index]
        actor_loss = -torch.min(surr1, surr2) - self.entropy_coef * dist_entropy  # Trick 5: policy entropy
        # Update actor
        self.optimizer_actor.zero_grad()
        actor_loss.mean().backward()
        if self.use_grad_clip:  # Trick 7: Gradient clip
            torch.nn.utils.clip_grad_norm_(self.actor.parameters(), 0.5)
        self.optimizer_actor.step()

        v_s = self.critic(s[index], a[index])
        critic_loss = F.mse_loss(v_target[index], v_s)
        self.critic_loss.append(critic_loss.item())

        # Update critic
        self.optimizer_critic.zero_grad()
        critic_loss.backward()
        if self.use_grad_clip:  # Trick 7: Gradient clip
            torch.nn.utils.clip_grad_norm_(self.critic.parameters(), 0.5)
        self.optimizer_critic.step()

2.将所有的torch.tensor更改为mindspore.Tensor,参考文档,认为此替换不太可能造成问题

另外,我们也将文档中神经网络的mindspore示例运行了一遍,采用相同的梯度更新方法,但并没有出现内存增长的问题。我们不知道是迁移的训练过程有误,还是其它的迁移项不能对应。

我要发帖子