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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new f7ab07c  [Enhancement]Schema change error prompts the table name (#61)
f7ab07c is described below

commit f7ab07c18b8dc7b40adcd8ffaa404db5d009a9d6
Author: wudongliang <46414265+donglian...@users.noreply.github.com>
AuthorDate: Wed Jan 22 10:18:34 2025 +0800

    [Enhancement]Schema change error prompts the table name (#61)
---
 .../java/org/apache/doris/kafka/connector/converter/RecordService.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java 
b/src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java
index e4fcf95..81afbd0 100644
--- 
a/src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java
+++ 
b/src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java
@@ -184,7 +184,7 @@ public class RecordService {
                     "Table '{}' cannot be altered because schema evolution is 
disabled.",
                     tableName);
             throw new SchemaChangeException(
-                    "Cannot alter table " + table + " because schema evolution 
is disabled");
+                    "Cannot alter table " + tableName + " because schema 
evolution is disabled");
         }
         for (RecordDescriptor.FieldDescriptor missingField : missingFields) {
             schemaChangeManager.addColumnDDL(tableName, missingField);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to