Skip to content

CI测试不review[fluid_ops] test send_v2 #72062

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 2 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -348,7 +348,7 @@ void FakeInitializeTensor(const phi::DeviceContext& dev_ctx,
PADDLE_ENFORCE_EQ(place,
dev_ctx.GetPlace(),
common::errors::Unavailable(
"The place %s for fack alloc is not equal to "
"The place %s for fake alloc is not equal to "
"the place %s of DeviceContext.",
place,
dev_ctx.GetPlace()));
Expand Down Expand Up @@ -525,7 +525,7 @@ void RunWhileBlockPreStaticBuild(const framework::Scope& scope,
// note(lvyongkang): The assign op in while loop may change the place of
// variable. However, InterpreterCore fix the kernel of every ops during its
// first run. A cpu tensor may become gpu tensor after first run. This will
// lead to segmetation fault when it's used in a cpu kernel. Here we record
// lead to segmentation fault when it's used in a cpu kernel. Here we record
// the place of every inputs and restore their place after
// InterpreterCore.run().
std::map<std::string, phi::Place> input_var_original_places;
Expand Down Expand Up @@ -696,7 +696,7 @@ void FakeInitializeOutputsForOperatorBase(
if (following_input_vars.count(var_name)) {
PADDLE_THROW(common::errors::PreconditionNotMet(
"The output %s s' dtype/place of %s is "
"changed after static build. Befer static build, the "
"changed after static build. Before static build, the "
"dtype is %s, place is %s. After static "
"build, the dtype is %s, place is %s.",
op_type,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -450,8 +450,8 @@ void BuildValue(pir::Value value,
} else {
PADDLE_THROW(common::errors::PreconditionNotMet(
"Output only support DenseTensorType "
"or SelectedRowsType or VectorType or StackType or SpasrCooTensorType "
"or SpasreCsrTensorType"));
"or SelectedRowsType or VectorType or StackType or SparseCooTensorType "
"or SparseCsrTensorType"));
}
}

Expand Down Expand Up @@ -710,9 +710,9 @@ bool IsNeedVarInplace(pir::Operation* op,

// NOTE(chenxi67): Here, we only perform inplace processing for variables that
// need to be inplaced by var (mostly, whose type is TensorArray or re-Allocated
// Densetensor). For other types of variables, we only share the holder of
// DenseTensor). For other types of variables, we only share the holder of
// DenseTensor but not the var*. The reason is that vector<DenseTensor> in
// TensorArray (or re-Allocated Densetensor) cannot be shared totally.
// TensorArray (or re-Allocated DenseTensor) cannot be shared totally.
void HandleForInplaceVarOp(pir::Operation* op,
const std::string& var_name_prefix,
ValueExecutionInfo* value_exe_info) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ class ThreadPoolTempl {
// and NonEmptyQueueIndex. Iteration is based on the fact that if we take
// a random starting thread index t and calculate num_threads - 1 subsequent
// indices as (t + coprime) % num_threads, we will cover all threads without
// repetitions (effectively getting a presudo-random permutation of thread
// repetitions (effectively getting a pseudo-random permutation of thread
// indices).
assert(num_threads_ >= 1 && num_threads_ < kMaxThreads);
all_coprimes_.reserve(num_threads_);
Expand Down
Loading