File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
src/test/scala/io/github/mtsongithub/doetl/sparkdialectextensions/clickhouse Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -507,6 +507,8 @@ class ClickhouseDialectTest
507507 val df = spark.read
508508 .format(" jdbc" )
509509 .option(" url" , jdbcUrl)
510+ .option(" user" , jdbcUser)
511+ .option(" password" , jdbcPassword)
510512 .option(" dbtable" , tableName)
511513 .load()
512514
@@ -566,6 +568,8 @@ class ClickhouseDialectTest
566568 val df = spark.read
567569 .format(" jdbc" )
568570 .option(" url" , jdbcUrl)
571+ .option(" user" , jdbcUser)
572+ .option(" password" , jdbcPassword)
569573 .option(" dbtable" , tableName)
570574 .load()
571575
@@ -662,9 +666,9 @@ class ClickhouseDialectTest
662666 df.write
663667 .format(" jdbc" )
664668 .option(" url" , jdbcUrl)
665- .option(" dbtable" , tableName)
666669 .option(" user" , jdbcUser)
667670 .option(" password" , jdbcPassword)
671+ .option(" dbtable" , tableName)
668672 .option(" createTableOptions" , " ENGINE = TinyLog" )
669673 .mode(" errorIfExists" )
670674 .save()
You can’t perform that action at this time.
0 commit comments