This is an automated email from the ASF dual-hosted git repository.
agrove pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 6f7c9a518 fix: Fix subcommands options in fuzz-testing (#2684)
6f7c9a518 is described below
commit 6f7c9a518e1977e25fa5541610106c2724be1ced
Author: Manu Zhang <[email protected]>
AuthorDate: Wed Nov 5 06:33:54 2025 +0800
fix: Fix subcommands options in fuzz-testing (#2684)
---
fuzz-testing/src/main/scala/org/apache/comet/fuzz/Main.scala | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/fuzz-testing/src/main/scala/org/apache/comet/fuzz/Main.scala
b/fuzz-testing/src/main/scala/org/apache/comet/fuzz/Main.scala
index b9e63c76a..ced2ad28c 100644
--- a/fuzz-testing/src/main/scala/org/apache/comet/fuzz/Main.scala
+++ b/fuzz-testing/src/main/scala/org/apache/comet/fuzz/Main.scala
@@ -47,7 +47,7 @@ class Conf(arguments: Seq[String]) extends
ScallopConf(arguments) {
addSubcommand(generateData)
object generateQueries extends Subcommand("queries") {
val numFiles: ScallopOption[Int] =
- opt[Int](required = false, descr = "Number of input files to use")
+ opt[Int](required = true, descr = "Number of input files to use")
val numQueries: ScallopOption[Int] =
opt[Int](required = true, descr = "Number of queries to generate")
val randomSeed: ScallopOption[Long] =
@@ -58,7 +58,9 @@ class Conf(arguments: Seq[String]) extends
ScallopConf(arguments) {
val filename: ScallopOption[String] =
opt[String](required = true, descr = "File to write queries to")
val numFiles: ScallopOption[Int] =
- opt[Int](required = false, descr = "Number of input files to use")
+ opt[Int](required = true, descr = "Number of input files to use")
+ val showFailedSparkQueries: ScallopOption[Boolean] =
+ opt[Boolean](required = false, descr = "Whether to show failed Spark
queries")
}
addSubcommand(runQueries)
verify()
@@ -107,7 +109,11 @@ object Main {
numFiles = conf.generateQueries.numFiles(),
conf.generateQueries.numQueries())
case Some(conf.runQueries) =>
- QueryRunner.runQueries(spark, conf.runQueries.numFiles(),
conf.runQueries.filename())
+ QueryRunner.runQueries(
+ spark,
+ conf.runQueries.numFiles(),
+ conf.runQueries.filename(),
+ conf.runQueries.showFailedSparkQueries())
case _ =>
// scalastyle:off println
println("Invalid subcommand")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
