This is an automated email from the ASF dual-hosted git repository.
yangzy 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 c5637f1185 [MINOR] Use passed TaskContext instead of TaskContext#get
(#9980)
c5637f1185 is described below
commit c5637f1185be265bacd0bad10953edf8cdca8551
Author: Yang Zhang <[email protected]>
AuthorDate: Mon Jun 16 18:37:49 2025 +0800
[MINOR] Use passed TaskContext instead of TaskContext#get (#9980)
---
.../scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
b/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
index 68f8b0e8a5..726c694e7f 100644
---
a/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
+++
b/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
@@ -262,7 +262,7 @@ class VeloxIteratorApi extends IteratorApi with Logging {
.protectInvocationFlow()
.recycleIterator {
updateNativeMetrics(itrMetrics.fetch(resIter))
- updateInputMetrics(TaskContext.get().taskMetrics().inputMetrics)
+ updateInputMetrics(context.taskMetrics().inputMetrics)
resIter.close()
}
.recyclePayload(batch => batch.close())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
