中文表streamload导入失败

... 4 more
[2026-03-15 17:40:39,669] INFO [doris-sink-new-coupon|task-0] kafka doris sink task closed with [ods_new_coupon-0, ods_new_coupon-1] (org.apache.doris.kafka.connector.DorisSinkTask:91)
[2026-03-15 17:40:39,669] ERROR [doris-sink-new-coupon|task-0] WorkerSinkTask{id=doris-sink-new-coupon-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:251)
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:658)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:359)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:261)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:225)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:243)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:298)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:251)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: org.apache.doris.kafka.connector.exception.DorisException: org.apache.doris.kafka.connector.exception.StreamLoadException: failed to stream load data with label: ods_new_coupon__KC_-1__KC_ods_ods_新券表_copy1__KC_1202__KC_562
at org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad.checkFlushException(AsyncDorisStreamLoad.java:140)
at org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad.checkException(AsyncDorisStreamLoad.java:156)
at org.apache.doris.kafka.connector.writer.AsyncStreamLoadWriter.checkFlushException(AsyncStreamLoadWriter.java:121)
at org.apache.doris.kafka.connector.writer.AsyncStreamLoadWriter.insert(AsyncStreamLoadWriter.java:71)
at org.apache.doris.kafka.connector.service.DorisCombinedSinkService.insert(DorisCombinedSinkService.java:110)
at org.apache.doris.kafka.connector.service.DorisCombinedSinkService.insert(DorisCombinedSinkService.java:98)
at org.apache.doris.kafka.connector.DorisSinkTask.put(DorisSinkTask.java:103)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:628)
... 11 more
Caused by: org.apache.doris.kafka.connector.exception.StreamLoadException: failed to stream load data with label: ods_new_coupon__KC_-1__KC_ods_ods_新券表_copy1__KC_1202__KC_562
at org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.load(AsyncDorisStreamLoad.java:247)
at org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.run(AsyncDorisStreamLoad.java:175)
... 3 more
Caused by: org.apache.doris.kafka.connector.exception.StreamLoadException: stream load error: [DATA_QUALITY_ERROR]Encountered unqualified data, stop processing. Please check if the source data matches the schema, and consider disabling strict mode or increasing max_filter_ratio.. cur path: , see more in http://192.168.1.118:8040/api/_load_error_log?file=__shard_21/error_log_insert_stmt_cf43db9a0f8ca6fe-2b8facbbed2db18a_cf43db9a0f8ca6fe_2b8facbbed2db18a
at org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.load(AsyncDorisStreamLoad.java:230)
... 4 more