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 b7da15d
Showing 1 changed file with 12 additions and 1 deletion.
13 changes: 12 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,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;
Expand Down Expand Up @@ -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"));

Expand Down Expand Up @@ -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 ========");
}
Expand Down Expand Up @@ -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";
}
}

0 comments on commit b7da15d

Please sign in to comment.