Skip to content

Commit 67b5711

Browse files
committed
fix
1 parent cecc144 commit 67b5711

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

cpp/velox/compute/WholeStageResultIterator.cc

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,11 @@ WholeStageResultIterator::WholeStageResultIterator(
120120
velox::core::PlanFragment planFragment{planNode, velox::core::ExecutionStrategy::kUngrouped, 1, emptySet};
121121
std::shared_ptr<velox::core::QueryCtx> queryCtx = createNewVeloxQueryCtx();
122122
task_ = velox::exec::Task::create(
123-
getVeloxTaskId(taskInfo_),
123+
fmt::format(
124+
"Gluten_Stage_{}_TID_{}_VTID_{}",
125+
std::to_string(taskInfo_.stageId),
126+
std::to_string(taskInfo_.taskId),
127+
std::to_string(taskInfo_.vId)),
124128
std::move(planFragment),
125129
0,
126130
std::move(queryCtx),

0 commit comments

Comments
 (0)