[pulsar] branch branch-2.11 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-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


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

commit 0e9e8b0ddda2f99cdac09035931b0a94dc36d3b3
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 827612f48be..01d27a22754 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 684ac5d2c74..f4bcc2c3488 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
@@ -71,7 +71,7 @@ public class PulsarSqlSchemaInfoProvider implements 
SchemaInfoProvider {
             }
             return 
completedFuture(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());
         }