Fix error message format

chenjian2664 · wendigo · commit 5213e2267430 · 2025-07-28T18:18:06.000+02:00
Fix error message format in `ConfluentAvroReaderSupplier` and
`ConfluentSchemaRegistryDynamicMessageProvider `
diff --git a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentAvroReaderSupplier.java b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentAvroReaderSupplier.java
@@ -58,7 +58,7 @@ private GenericDatumReader<T> lookupReader(int id)
             return new GenericDatumReader<>(sourceSchema, targetSchema);
         }
         catch (IOException | RestClientException e) {
-            throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s'from confluent schema registry failed", id), e);
+            throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s' from confluent schema registry failed", id), e);
         }
     }
 
diff --git a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentSchemaRegistryDynamicMessageProvider.java b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentSchemaRegistryDynamicMessageProvider.java
@@ -81,7 +81,7 @@ private Descriptor lookupDescriptor(int schemaId)
             return ((ProtobufSchema) schema).toDescriptor();
         }
         catch (IOException | RestClientException e) {
-            throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s'from confluent schema registry failed", schemaId), e);
+            throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s' from confluent schema registry failed", schemaId), e);
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ private GenericDatumReader<T> lookupReader(int id)`
`58`	`58`	`return new GenericDatumReader<>(sourceSchema, targetSchema);`
`59`	`59`	`}`
`60`	`60`	`catch (IOException \| RestClientException e) {`
`61`		`- throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s'from confluent schema registry failed", id), e);`
	`61`	`+ throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s' from confluent schema registry failed", id), e);`
`62`	`62`	`}`
`63`	`63`	`}`
`64`	`64`
Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,7 @@ private Descriptor lookupDescriptor(int schemaId)`
`81`	`81`	`return ((ProtobufSchema) schema).toDescriptor();`
`82`	`82`	`}`
`83`	`83`	`catch (IOException \| RestClientException e) {`
`84`		`- throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s'from confluent schema registry failed", schemaId), e);`
	`84`	`+ throw new TrinoException(GENERIC_INTERNAL_ERROR, format("Looking up schemaId '%s' from confluent schema registry failed", schemaId), e);`
`85`	`85`	`}`
`86`	`86`	`}`
`87`	`87`