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