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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
