From b7da15d9b182b232f18636748525019bae465a22 Mon Sep 17 00:00:00 2001 From: "Mateusz \"Serafin\" Gajewski" Date: Mon, 12 Aug 2024 14:52:08 +0200 Subject: [PATCH] Log native compression status during startup --- .../src/main/java/io/trino/server/Server.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/core/trino-main/src/main/java/io/trino/server/Server.java b/core/trino-main/src/main/java/io/trino/server/Server.java index 73527d731bf43..c85d613a7b4f4 100644 --- a/core/trino-main/src/main/java/io/trino/server/Server.java +++ b/core/trino-main/src/main/java/io/trino/server/Server.java @@ -22,6 +22,9 @@ import com.google.inject.TypeLiteral; import io.airlift.bootstrap.ApplicationConfigurationException; import io.airlift.bootstrap.Bootstrap; +import io.airlift.compress.v2.lz4.Lz4NativeCompressor; +import io.airlift.compress.v2.snappy.SnappyNativeCompressor; +import io.airlift.compress.v2.zstd.ZstdNativeCompressor; import io.airlift.discovery.client.Announcer; import io.airlift.discovery.client.DiscoveryModule; import io.airlift.discovery.client.ServiceAnnouncement; @@ -142,6 +145,10 @@ private void doStart(String trinoVersion) Injector injector = app.initialize(); log.info("Trino version: %s", injector.getInstance(NodeVersion.class).getVersion()); + log.info("Zstandard native compression: %s", formatEnabled(ZstdNativeCompressor.isEnabled())); + log.info("Lz4 native compression: %s", formatEnabled(Lz4NativeCompressor.isEnabled())); + log.info("Snappy native compression: %s", formatEnabled(SnappyNativeCompressor.isEnabled())); + logLocation(log, "Working directory", Paths.get(".")); logLocation(log, "Etc directory", Paths.get("etc")); @@ -190,7 +197,6 @@ private void doStart(String trinoVersion) injector.getInstance(Announcer.class).start(); injector.getInstance(StartupStatus.class).startupComplete(); - log.info("Server startup completed in %s", Duration.nanosSince(startTime).convertToMostSuccinctTimeUnit()); log.info("======== SERVER STARTED ========"); } @@ -292,4 +298,9 @@ private static void logLocation(Logger log, String name, Path path) } log.info("%s: %s", name, path); } + + private static String formatEnabled(boolean flag) + { + return flag ? "enabled" : "disabled"; + } }