Skip to content

Commit 001b134

Browse files
authored
[improve][sql] Fix the wrong format of the logs (apache#20907)
1 parent ca01447 commit 001b134

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -776,7 +776,7 @@ private void initEntryCacheSizeAllocator(PulsarConnectorConfig connectorConfig)
776776
connectorConfig.getMaxSplitQueueSizeBytes() / 2);
777777
this.messageQueueCacheSizeAllocator = new NoStrictCacheSizeAllocator(
778778
connectorConfig.getMaxSplitQueueSizeBytes() / 2);
779-
log.info("Init cacheSizeAllocator with maxSplitEntryQueueSizeBytes {}.",
779+
log.info("Init cacheSizeAllocator with maxSplitEntryQueueSizeBytes %d.",
780780
connectorConfig.getMaxSplitQueueSizeBytes());
781781
} else {
782782
this.entryQueueCacheSizeAllocator = new NullCacheSizeAllocator();

pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public CompletableFuture<SchemaInfo> getSchemaByVersion(byte[] schemaVersion) {
7474
}
7575
return cache.get(BytesSchemaVersion.of(schemaVersion));
7676
} catch (ExecutionException e) {
77-
LOG.error("Can't get generic schema for topic {} schema version {}",
77+
LOG.error("Can't get generic schema for topic %s schema version %s",
7878
topicName.toString(), new String(schemaVersion, StandardCharsets.UTF_8), e);
7979
return FutureUtil.failedFuture(e.getCause());
8080
}

0 commit comments

Comments
 (0)