Optimize log message in Redis and Kafka

trinodb · May 23, 2022 · be2b53c · be2b53c
1 parent cb18890
commit be2b53c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...o-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java b/...o-kafka/src/main/java/io/trino/plugin/kafka/schema/file/FileTableDescriptionSupplier.java
@@ -124,7 +124,7 @@ private Map<SchemaTableName, KafkaTopicDescription> 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
@@ -93,7 +93,7 @@ public Map<SchemaTableName, RedisTableDescription> 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);
         }
     }