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.")
}
}