[pulsar] branch branch-3.0 updated: [improve][sql] Fix the wrong format of the logs (#20907)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new a6b475c8531 [improve][sql] Fix the wrong format of the logs (#20907)
a6b475c8531 is described below

commit a6b475c85318e76500cab6f9757116562f090546
Author: crossoverJie <crossover...@gmail.com>
AuthorDate: Mon Jul 31 20:40:29 2023 +0800

    [improve][sql] Fix the wrong format of the logs (#20907)
---
 .../src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java  | 2 +-
 .../java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
 
b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
index f86335ae378..42a69b142e4 100644
--- 
a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
+++ 
b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
@@ -767,7 +767,7 @@ public class PulsarRecordCursor implements RecordCursor {
                     connectorConfig.getMaxSplitQueueSizeBytes() / 2);
             this.messageQueueCacheSizeAllocator = new 
NoStrictCacheSizeAllocator(
                     connectorConfig.getMaxSplitQueueSizeBytes() / 2);
-            log.info("Init cacheSizeAllocator with maxSplitEntryQueueSizeBytes 
{}.",
+            log.info("Init cacheSizeAllocator with maxSplitEntryQueueSizeBytes 
%d.",
                     connectorConfig.getMaxSplitQueueSizeBytes());
         } else {
             this.entryQueueCacheSizeAllocator = new NullCacheSizeAllocator();
diff --git 
a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
 
b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
index e2d030d2d7f..673ea2b3940 100644
--- 
a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
+++ 
b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
@@ -74,7 +74,7 @@ public class PulsarSqlSchemaInfoProvider implements 
SchemaInfoProvider {
             }
             return cache.get(BytesSchemaVersion.of(schemaVersion));
         } catch (ExecutionException e) {
-            LOG.error("Can't get generic schema for topic {} schema version 
{}",
+            LOG.error("Can't get generic schema for topic %s schema version 
%s",
                     topicName.toString(), new String(schemaVersion, 
StandardCharsets.UTF_8), e);
             return FutureUtil.failedFuture(e.getCause());
         }