diff --git a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java index 9df95426d141..888fe02320a8 100644 --- a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java +++ b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java @@ -124,7 +124,7 @@ private Map populateTables() return builder.buildOrThrow(); } catch (IOException e) { - log.warn(e, "Error: "); + log.warn(e, "Failed to get table description files for Kafka"); throw new UncheckedIOException(e); } } diff --git a/plugin/trino-redis/src/main/java/io/trino/plugin/redis/RedisTableDescriptionSupplier.java b/plugin/trino-redis/src/main/java/io/trino/plugin/redis/RedisTableDescriptionSupplier.java index 79eecd138046..dc29a9df63f4 100644 --- a/plugin/trino-redis/src/main/java/io/trino/plugin/redis/RedisTableDescriptionSupplier.java +++ b/plugin/trino-redis/src/main/java/io/trino/plugin/redis/RedisTableDescriptionSupplier.java @@ -93,7 +93,7 @@ public Map get() return builder.buildOrThrow(); } catch (IOException e) { - log.warn(e, "Error: "); + log.warn(e, "Failed to get table description files for Redis"); throw new UncheckedIOException(e); } }