ods_doris.t_log_rt表结构关键信息:

任务之前正常运行很长一段时间,异常报错如下:
2026-01-07 00:01:15,618 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Writer -> Sink: Committer (1/1) (0a0e0e9171a3ed3234fb3ae896896d07_c68af6bfd3068706be09d928336f9947_0_5) switched from RUNNING to FAILED on container_e16_1749529848410_93430_01_000002 @ slave01 (dataPort=42666).
java.io.IOException: Could not perform checkpoint 418424 for operator Sink: Writer -> Sink: Committer (1/1)#5.
.......省略
Caused by: org.apache.doris.flink.exception.DorisRuntimeException: table ods_doris.t_log_rt stream load error: [RUNTIME_ERROR]TStatus: create partition failed. error:errCode = 2, detailMessage = Range [types: [DATEV2]; keys: [2026-01-07]; ..types: [DATEV2]; keys: [2026-01-08]; ) is intersected with range: [types: [DATEV2]; keys: [2026-01-07]; ..types: [DATEV2]; keys: [2026-01-08]; )
0# doris::Status doris::Status::create<true>(doris::TStatus const&) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
1# doris::vectorized::VRowDistribution::automatic_create_partition() at /home/zcp/repo_center/doris_release/doris/be/src/vec/sink/vrow_distribution.cpp:115
2# doris::vectorized::VTabletWriter::_send_new_partition_batch() at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:502
3# doris::vectorized::VTabletWriter::_do_try_close(doris::RuntimeState*, doris::Status const&) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:389
4# doris::vectorized::VTabletWriter::close(doris::Status) at /home/zcp/repo_center/doris_release/doris/be/src/vec/sink/writer/vtablet_writer.cpp:1561
5# doris::vectorized::AsyncResultWriter::process_block(doris::RuntimeState*, doris::RuntimeProfile*) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/unique_ptr.h:360
6# std::_Function_handler<void (), doris::vectorized::AsyncResultWriter::start_writer(doris::RuntimeState*, doris::RuntimeProfile*)::$_0>::_M_invoke(std::_Any_data const&) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/ext/atomicity.h:98
7# doris::ThreadPool::dispatch_thread() at /home/zcp/repo_center/doris_release/doris/be/src/util/threadpool.cpp:0
8# doris::Thread::supervise_thread(void*) at /var/local/ldb-toolchain/bin/../usr/include/pthread.h:562
9# start_thread
10# clone
, see more in null
at org.apache.doris.flink.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:331) ~[flink-doris-connector-1.19-25.1.0.jar:25.1.0]
at org.apache.doris.flink.sink.writer.DorisWriter.prepareCommit(DorisWriter.java:236) ~[flink-doris-connector-1.19-25.1.0.jar:25.1.0]
表的分区是自动创建的,看日志说是重复创建分区失败,不知道为什么会重复创建