Skip to content

Commit

Permalink
Log native compression status during startup
Browse files Browse the repository at this point in the history
  • Loading branch information
wendigo committed Aug 12, 2024
1 parent ca87bfe commit 23d5efe
Showing 1 changed file with 13 additions and 1 deletion.
14 changes: 13 additions & 1 deletion core/trino-main/src/main/java/io/trino/server/Server.java
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,10 @@
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.lz4.Lz4NativeDecompressor;
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;
Expand Down Expand Up @@ -142,6 +146,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"));

Expand Down Expand Up @@ -190,7 +198,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 ========");
}
Expand Down Expand Up @@ -292,4 +299,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";
}
}

0 comments on commit 23d5efe

Please sign in to comment.