Skip to content

Commit 2aa732b

Browse files
committed
fix distribute transpiler to optimize selected rows
1 parent 4f10039 commit 2aa732b

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

paddle/fluid/framework/operator.cc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -679,6 +679,8 @@ void OperatorWithKernel::RunImpl(const Scope& scope,
679679
if (var == nullptr) continue;
680680
if (var->IsType<framework::LoDTensor>()) {
681681
CheckTensorNANOrInf(vname, var->Get<framework::LoDTensor>());
682+
} else if (var->IsType<framework::SelectedRows>()) {
683+
CheckTensorNANOrInf(vname, var->Get<framework::SelectedRows>().value());
682684
}
683685
}
684686
}

python/paddle/fluid/transpiler/distribute_transpiler.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -494,6 +494,7 @@ def __clone_lr_op_sub_block__(op, program, lr_block):
494494
pserver_index = self.pserver_endpoints.index(endpoint)
495495
table_opt_block = self._create_table_optimize_block(
496496
pserver_index, pserver_program, pre_block_idx, grad_to_block_id)
497+
optimize_blocks.append(table_opt_block)
497498
prefetch_var_name_to_block_id = self._create_prefetch_block(
498499
pserver_index, pserver_program, table_opt_block)
499500
checkpoint_block_id = self._create_checkpoint_save_block(

0 commit comments

Comments
 (0)