Skip to content

Commit c1ce7aa

Browse files
committed
ice: Log iceberg properties in debug mode
1 parent 06e66a2 commit c1ce7aa

File tree

1 file changed

+13
-1
lines changed
  • ice/src/main/java/com/altinity/ice/cli

1 file changed

+13
-1
lines changed

ice/src/main/java/com/altinity/ice/cli/Main.java

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import java.util.HashSet;
2828
import java.util.List;
2929
import java.util.Scanner;
30+
import java.util.stream.Collectors;
3031
import org.apache.iceberg.catalog.TableIdentifier;
3132
import org.apache.iceberg.rest.RESTCatalog;
3233
import org.slf4j.Logger;
@@ -370,7 +371,18 @@ void deleteTable(
370371
private RESTCatalog loadCatalog(String configFile) throws IOException {
371372
Config config = Config.load(configFile);
372373
RESTCatalog catalog = new RESTCatalog();
373-
catalog.initialize("default", config.toIcebergConfig());
374+
var icebergConfig = config.toIcebergConfig();
375+
logger.debug(
376+
"Iceberg configuration: {}",
377+
icebergConfig.entrySet().stream()
378+
.map(
379+
e ->
380+
!e.getKey().contains("key") && !e.getKey().contains("authorization")
381+
? e.getKey() + "=" + e.getValue()
382+
: e.getKey())
383+
.sorted()
384+
.collect(Collectors.joining(", ")));
385+
catalog.initialize("default", icebergConfig);
374386
return catalog;
375387
}
376388

0 commit comments

Comments
 (0)