Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
cxzl25 committed Mar 4, 2022
1 parent fa1e899 commit c3895b2
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -235,8 +235,10 @@ object ServiceControlCli extends CommandLineUtils with Logging {
val engineSubdomain = Some(args.cliArgs.engineSubdomain)
.filter(_ != null).filter(_.nonEmpty)
.getOrElse(args.conf.get(ENGINE_SHARE_LEVEL_SUBDOMAIN).getOrElse("default"))
ZKPaths.makePath(s"${args.cliArgs.namespace}_${ShareLevel.USER}_${engineType}",
args.cliArgs.user, engineSubdomain)
ZKPaths.makePath(
s"${args.cliArgs.namespace}_${ShareLevel.USER}_${engineType}",
args.cliArgs.user,
engineSubdomain)
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -429,8 +429,7 @@ class ServiceControlCliSuite extends KyuubiFunSuite with TestPrematureExit {
"--user",
user,
"--engine-type",
"FLINK_SQL"
)
"FLINK_SQL")
assert(getZkNamespace(new ServiceControlCliArguments(arg2)) ==
s"/${namespace}_USER_FLINK_SQL/$user/default")

Expand All @@ -444,8 +443,7 @@ class ServiceControlCliSuite extends KyuubiFunSuite with TestPrematureExit {
"--user",
user,
"--engine-type",
"TRINO"
)
"TRINO")
assert(getZkNamespace(new ServiceControlCliArguments(arg3)) ==
s"/${namespace}_USER_TRINO/$user/default")

Expand All @@ -461,8 +459,7 @@ class ServiceControlCliSuite extends KyuubiFunSuite with TestPrematureExit {
"--engine-type",
"SPARK_SQL",
"--engine-subdomain",
"sub_1"
)
"sub_1")
assert(getZkNamespace(new ServiceControlCliArguments(arg4)) ==
s"/${namespace}_USER_SPARK_SQL/$user/sub_1")
}
Expand Down

0 comments on commit c3895b2

Please sign in to comment.