Skip to content

Commit

Permalink
Remove log & fix code format
Browse files Browse the repository at this point in the history
  • Loading branch information
mzitnik committed Jul 16, 2024
1 parent 3bd7dae commit 10339d7
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -125,8 +125,7 @@ class ClickHouseCatalog extends TableCatalog
throw new NoSuchTableException(s"Database $db does not exist")
case Left(rethrow) =>
throw rethrow
case Right(_) =>
(db, tbl)
case Right(_) => (db, tbl)
}
}
implicit val _tz: ZoneId = tz.merge
Expand Down Expand Up @@ -238,7 +237,6 @@ class ClickHouseCatalog extends TableCatalog
table: String,
settingsClause: String
): Unit = {
log.debug(s"createTable($clusterOpt, $engineExpr, $database, $table, $settingsClause)")
val clusterClause = clusterOpt.map(c => s"ON CLUSTER $c").getOrElse("")
nodeClient.syncQueryAndCheckOutputJSONEachRow(
s"""CREATE TABLE `$database`.`$table` $clusterClause (
Expand Down

0 comments on commit 10339d7

Please sign in to comment.