chaijun888-tech opened a new issue, #10063: URL: https://github.com/apache/seatunnel/issues/10063
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened We upgraded our OB→Doris sync job to SeaTunnel 2.3.12 (fresh binary with the official connector-doris- 2.3.12.jar, connector-jdbc-2.3.12.jar, and MySQL driver). The job starts and reaches the Doris sink, but every Stream Load attempt still fails with HTTP/1.1 400 No Host. Doris FE is running 2.1.11 and enforces Stream Load redirect to BE nodes; SeaTunnel sends the first request with Host: 192.168.0.61:8030, FE responds with 307, but after the redirect the sink receives a 400 “No Host” from FE/BE. We verified the same Host value works with curl -L and with the original FE endpoint, so the only failure path is the SeaTunnel Doris connector’s redirected HTTP request losing the Host header. Even after upgrading to 2.3.12 (which should support redirect), the connector still replays the redirect with the BE host and Doris rejects it. ### SeaTunnel Version 2.3.12 ### SeaTunnel Config ```conf env { job.mode = "BATCH" parallelism = 1 } source { Jdbc { result_table_name = "ts_msg_log_src" driver = "com.mysql.cj.jdbc.Driver" url = "jdbc:mysql://192.168.0.57:2883/db_ysbc_log?useUnicode=true&characterEncoding=utf8&useSSL=false" user = "**@**#ob" password = "**" query = "SELECT id, send_code, carrier_id, send_url, msg_content, result_code, ctime FROM ts_msg_log" } } sink { Doris { source_table_name = "ts_msg_log_src" fenodes = "192.168.0.61:8030" username = "root" password = "" table_identifier = "ods_db_ysbc_log.ts_msg_log" database = "ods_db_ysbc_log" table = "ts_msg_log" default_database = "ods_db_ysbc_log" schema_save_mode = "ERROR_WHEN_SCHEMA_NOT_EXIST" data_save_mode = "APPEND_DATA" sink.enable_delete = false sink.label-prefix = "ts_msg_log_full" batch_size = 5000 doris.config = { "format" = "csv" "column_separator" = "\t" "row_delimiter" = "\n" "buffer_size" = "10485760" # "Host" = "192.168.0.61:8030" } } } ``` ### Running Command ```shell cd /opt/seatunnel bin/seatunnel.sh --config config/db_ysbc_log_full_ts_msg_log.conf -m local | tee /tmp/seatunnel_ts_msg_log_full.log ``` ### Error Exception ```log 2025-11-13 15:20:34,117 WARN [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=1}] - No split key found for table db_ysbc_log.ts_msg_log 2025-11-13 15:20:34,119 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=1}] - Split table db_ysbc_log.ts_msg_log into 1 chunks, time cost: 3ms. 2025-11-13 15:20:34,119 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=1}] - Split table db_ysbc_log.ts_msg_log into 1 splits. 2025-11-13 15:20:34,134 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=1}] - No more splits to assign. Sending NoMoreSplitsEvent to reader [0]. 2025-11-13 15:20:34,202 INFO [o.a.s.c.d.s.w.RecordBuffer ] [st-multi-table-sink-writer-1] - start buffer data, read queue size 0, write queue size 3 2025-11-13 15:20:34,216 INFO [o.a.s.c.d.s.w.DorisStreamLoad ] [st-multi-table-sink-writer-1] - stream load started for ts_msg_log_full_ods_db_ysbc_log_ts_msg_log_1041251198021140481_0_1763018433994 2025-11-13 15:20:34,252 INFO [o.a.s.c.d.s.w.DorisStreamLoad ] [stream-load-upload] - start execute load 2025-11-13 15:20:34,648 INFO [o.a.s.c.d.s.w.DorisStreamLoad ] [st-multi-table-sink-writer-1] - stream load stopped. 2025-11-13 15:20:34,651 ERROR [a.s.m.MultiTableWriterRunnable] [st-multi-table-sink-writer-1] - MultiTableWriterRunnable error when write row SeaTunnelRow{tableId=db_ysbc_log.ts_msg_log, kind=+I, fields=[1024, 13000000001, 2, http://web.cr6868.com/asmx/smsservice.aspx, 有一笔订单已经付款，请尽快完成备货和送货。, 0, 1439698843]} org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:231) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.flush(DorisSinkWriter.java:203) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:169) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:60) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) [seatunnel-starter.jar:2.3.12] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] - HTTP/1.1 400 No Host at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.handlePreCommitResponse(DorisStreamLoad.java:220) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:229) ~[connector-doris-2.3.12.jar:2.3.12] ... 10 more 2025-11-13 15:20:34,667 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@5184d0f6 java.lang.RuntimeException: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:82) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) [seatunnel-starter.jar:2.3.12] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:140) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:184) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:269) ~[seatunnel-starter.jar:2.3.12] ... 17 more Caused by: org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:231) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.flush(DorisSinkWriter.java:203) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:169) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:60) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ~[seatunnel-starter.jar:2.3.12] ... 6 more Caused by: org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] - HTTP/1.1 400 No Host at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.handlePreCommitResponse(DorisStreamLoad.java:220) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:229) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.flush(DorisSinkWriter.java:203) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:169) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:60) ~[connector-doris-2.3.12.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ~[seatunnel-starter.jar:2.3.12] ... 6 more 2025-11-13 15:20:34,670 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] taskDone, taskId = 1000200010000, taskGroup = TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2} 2025-11-13 15:20:34,670 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] task 1000200010000 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}. 2025-11-13 15:20:34,740 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@472bc24d java.lang.RuntimeException: java.lang.InterruptedException at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:47) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:194) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:111) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader.pollNext(JdbcSourceReader.java:70) ~[connector-jdbc-2.3.12.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) [seatunnel-starter.jar:2.3.12] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1261) ~[?:?] at java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:317) ~[?:?] at java.util.concurrent.ArrayBlockingQueue.put(ArrayBlockingQueue.java:364) ~[?:?] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:82) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:44) ~[seatunnel-starter.jar:2.3.12] ... 17 more 2025-11-13 15:20:34,742 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2} 2025-11-13 15:20:34,757 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] taskGroup TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2} complete with FAILED 2025-11-13 15:20:34,761 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-539396] [5.1] task 1000200000000 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}. 2025-11-13 15:20:34,763 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-23] - log event: ReaderCloseEvent(createdTime=1763018434762, jobId=1041251198021140481, eventType=LIFECYCLE_READER_CLOSE) 2025-11-13 15:20:34,766 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-3] - [localhost]:5801 [seatunnel-539396] [5.1] Task TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2} complete with state FAILED 2025-11-13 15:20:34,766 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-3] - [localhost]:5801 [seatunnel-539396] [5.1] Received task end from execution TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}, state FAILED 2025-11-13 15:20:34,772 ERROR [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-3] - Job (1041251198021140481), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)], taskGroupLocation: [TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2}] end with state FAILED and Exception: java.lang.RuntimeException: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:82) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.lang.RuntimeException: table db_ysbc_log.ts_msg_log sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:140) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:184) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:269) ... 17 more Caused by: org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:231) at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.flush(DorisSinkWriter.java:203) at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:169) at org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:60) at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ... 6 more Caused by: org.apache.seatunnel.connectors.doris.exception.DorisConnectorException: ErrorCode:[Doris-01], ErrorDescription:[stream load error] - HTTP/1.1 400 No Host at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.handlePreCommitResponse(DorisStreamLoad.java:220) at org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:229) ... 10 more 2025-11-13 15:20:34,772 ERROR [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-9] - Task TaskGroupLocation{jobId=1041251198021140481, pipelineId=1, taskGroupId=2} Failed in Job SeaTunnel_Job (1041251198021140481), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. ...... 2025-11-13 15:20:48,902 INFO [s.c.s.s.c.ClientExecuteCommand] [SeaTunnel-CompletableFuture-Thread-1] - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version 使用 SeaTunnel Engine (Zeta) 2.3.12 版本 ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
