This is an automated email from the ASF dual-hosted git repository.
hongze pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 61033b719f [GLUTEN-7243][VL] A follow-up fix for #7748 (#7935)
61033b719f is described below
commit 61033b719f8494ef80dd0c46fa6e738afa7e732d
Author: Hongze Zhang <[email protected]>
AuthorDate: Wed Nov 13 19:33:08 2024 +0800
[GLUTEN-7243][VL] A follow-up fix for #7748 (#7935)
---
cpp/velox/operators/plannodes/RowVectorStream.h | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/cpp/velox/operators/plannodes/RowVectorStream.h
b/cpp/velox/operators/plannodes/RowVectorStream.h
index ce26305fa0..e5a469afee 100644
--- a/cpp/velox/operators/plannodes/RowVectorStream.h
+++ b/cpp/velox/operators/plannodes/RowVectorStream.h
@@ -46,7 +46,7 @@ class RowVectorStream {
// As of now, non-zero running threads usually happens when:
// 1. Task A spills task B;
// 2. Task A trys to grow buffers created by task B, during which spill
is requested on task A again.
- facebook::velox::exec::SuspendedSection(driverCtx_->driver);
+ facebook::velox::exec::SuspendedSection ss(driverCtx_->driver);
hasNext = iterator_->hasNext();
}
if (!hasNext) {
@@ -64,7 +64,7 @@ class RowVectorStream {
{
// We are leaving Velox task execution and are probably entering Spark
code through JNI. Suspend the current
// driver to make the current task open to spilling.
- facebook::velox::exec::SuspendedSection(driverCtx_->driver);
+ facebook::velox::exec::SuspendedSection ss(driverCtx_->driver);
cb = iterator_->next();
}
const std::shared_ptr<VeloxColumnarBatch>& vb =
VeloxColumnarBatch::from(pool_, cb);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
