Skip to content

Commit

Permalink
Fix spootless format
Browse files Browse the repository at this point in the history
  • Loading branch information
mzitnik committed Jul 9, 2024
1 parent 146d799 commit bda4426
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,11 +48,10 @@ trait SparkTest extends QueryTest with SharedSparkSession {
.set("spark.sql.codegen.wholeStage", "false")
.set("spark.sql.shuffle.partitions", "2")

def runClickHouseSQL(sql: String, options: Map[String, String] = cmdRunnerOptions): DataFrame = {
def runClickHouseSQL(sql: String, options: Map[String, String] = cmdRunnerOptions): DataFrame =
// spark.conf.getAll.foreach(println)
// println("--------------------")
spark.executeCommand(classOf[ClickHouseCommandRunner].getName, sql, options)
}

def autoCleanupTable(
database: String,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,8 @@ class ClickHouseSingleSuite extends SparkClickHouseSingleTest {
import testImplicits._
override protected def beforeAll(): Unit = {
super.beforeAll()
Seq("db_t1",
Seq(
"db_t1",
"db_t2",
"db_part",
"db_part_date",
Expand All @@ -35,7 +36,13 @@ class ClickHouseSingleSuite extends SparkClickHouseSingleTest {
"db_multi_sort_col",
"db_trunc",
"db_del",
"db_rw", "db_metadata_col", "db_agg_col", "db_cor", "cache_db", "runtime_db").foreach {
"db_rw",
"db_metadata_col",
"db_agg_col",
"db_cor",
"cache_db",
"runtime_db"
).foreach {
database =>
println(s"Drop database $database")
runClickHouseSQL("DROP DATABASE IF EXISTS _" + database)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,6 @@ trait SparkClickHouseSingleTest extends SparkTest with ClickHouseSingleMixIn {
.set("spark.clickhouse.write.format", "json")
.set("spark.sql.catalog.clickhouse.option.ssl", isCloud.toString)


override def cmdRunnerOptions: Map[String, String] = Map(
"host" -> clickhouseHost,
"http_port" -> clickhouseHttpPort.toString,
Expand Down

0 comments on commit bda4426

Please sign in to comment.