Skip to content

Commit 14a2bab

Browse files
committed
Enhancement: Add test case.
1 parent 7b76043 commit 14a2bab

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

spark-connector-oceanbase/spark-connector-oceanbase-base/src/test/scala/com/oceanbase/spark/OBCatalogMySQLITCase.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,7 @@ class OBCatalogMySQLITCase extends OceanBaseMySQLTestBase {
153153
.config("spark.sql.catalog.ob.direct-load.enabled", "true")
154154
.config("spark.sql.catalog.ob.direct-load.host", getHost)
155155
.config("spark.sql.catalog.ob.direct-load.rpc-port", getRpcPort)
156+
.config("spark.sql.catalog.ob.direct-load.username", getUsername.split("@").head)
156157
.getOrCreate()
157158

158159
insertTestData(session, "products")

spark-connector-oceanbase/spark-connector-oceanbase-base/src/test/scala/com/oceanbase/spark/OceanBaseMySQLConnectorITCase.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@ class OceanBaseMySQLConnectorITCase extends OceanBaseMySQLTestBase {
7575
| "direct-load.enabled"=true,
7676
| "direct-load.host"="$getHost",
7777
| "direct-load.rpc-port"=$getRpcPort,
78+
| "direct-load.username"=${getUsername.split("@").head},
7879
| "direct-load.write-thread-num"="1"
7980
|);
8081
|""".stripMargin)

0 commit comments

Comments
 (0)