This is an automated email from the ASF dual-hosted git repository.

richox pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git


The following commit(s) were added to refs/heads/master by this push:
     new cad59430 [AURON #1593] Add Spark prefix for log option key (#1594)
cad59430 is described below

commit cad59430ce090b949f44d3be072707afc846375a
Author: zhangmang <[email protected]>
AuthorDate: Wed Nov 5 10:47:33 2025 +0800

    [AURON #1593] Add Spark prefix for log option key (#1594)
---
 .../org/apache/auron/spark/configuration/SparkAuronConfiguration.java  | 2 ++
 .../src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala   | 3 ++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/spark-extension/src/main/java/org/apache/auron/spark/configuration/SparkAuronConfiguration.java
 
b/spark-extension/src/main/java/org/apache/auron/spark/configuration/SparkAuronConfiguration.java
index 0a533342..e425c012 100644
--- 
a/spark-extension/src/main/java/org/apache/auron/spark/configuration/SparkAuronConfiguration.java
+++ 
b/spark-extension/src/main/java/org/apache/auron/spark/configuration/SparkAuronConfiguration.java
@@ -35,6 +35,8 @@ import scala.collection.immutable.List$;
  */
 public class SparkAuronConfiguration extends AuronConfiguration {
 
+    // When using getOptional, the prefix will be automatically completed. If 
you only need to print the Option key,
+    // please manually add the prefix.
     public static final String SPARK_PREFIX = "spark.";
 
     public static final ConfigOption<Boolean> UI_ENABLED = 
ConfigOptions.key("auron.ui.enabled")
diff --git 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
index 8f0e90e1..1f9c82a9 100644
--- 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
+++ 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
@@ -1217,7 +1217,8 @@ object NativeConverters extends Logging {
           aggBuilder.addAllChildren(convertedChildren.keys.asJava)
         } else {
           throw new NotImplementedError(s"Unsupported aggregate expression: 
(${e.getClass})," +
-            s" set ${SparkAuronConfiguration.UDAF_FALLBACK_ENABLE.key} to true 
to enable UDAF fallbacking.")
+            s" set 
${SparkAuronConfiguration.SPARK_PREFIX}${SparkAuronConfiguration.UDAF_FALLBACK_ENABLE.key}"
 +
+            s" to true to enable UDAF fallbacking.")
         }
 
     }

Reply via email to