This is an automated email from the ASF dual-hosted git repository.
philo-he pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 0d772818a2 [MINOR] Inline validation and surface key names in
per-thread enabling config (#13149)
0d772818a2 is described below
commit 0d772818a23b3c71f4f95c5bcc39d536011e54cf
Author: YangJie <[email protected]>
AuthorDate: Wed Sep 30 03:52:36 2026 -0400
[MINOR] Inline validation and surface key names in per-thread enabling
config (#13149)
---
.../org/apache/gluten/extension/GlutenSessionExtensions.scala | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git
a/gluten-core/src/main/scala/org/apache/gluten/extension/GlutenSessionExtensions.scala
b/gluten-core/src/main/scala/org/apache/gluten/extension/GlutenSessionExtensions.scala
index 6097b821e0..fbb4130202 100644
---
a/gluten-core/src/main/scala/org/apache/gluten/extension/GlutenSessionExtensions.scala
+++
b/gluten-core/src/main/scala/org/apache/gluten/extension/GlutenSessionExtensions.scala
@@ -44,7 +44,15 @@ private[gluten] class GlutenSessionExtensions
session =>
val glutenEnabledForThread =
Option(session.sparkContext.getLocalProperty(GLUTEN_ENABLE_FOR_THREAD_KEY))
- .forall(_.toBoolean)
+ .forall {
+ value =>
+ try value.toBoolean
+ catch {
+ case _: IllegalArgumentException =>
+ throw new IllegalArgumentException(
+ s"$GLUTEN_ENABLE_FOR_THREAD_KEY should be boolean, but
was $value")
+ }
+ }
val disabled = !glutenEnabledForThread
logDebug(s"Gluten is disabled by variable: glutenEnabledForThread:
$glutenEnabledForThread")
disabled
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
