这是 doris的报错：1105 - RpcException, msg: timeout when waiting for send fragments rpc, query timeout:60, left timeout for this operation:30, host: node1
2025-08-11 15:39:55 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:createPendingCheckpoint) - Triggering checkpoint 14 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1754897995343 for job 6bed03ec47291c6cbc650442810cac0f.
2025-08-11 15:39:55 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:logCheckpointInfo) - Completed checkpoint 14 for job 6bed03ec47291c6cbc650442810cac0f (18236 bytes, checkpointDuration=2 ms, finalizationTime=0 ms).
2025-08-11 15:39:55 INFO (org.apache.flink.runtime.source.coordinator.SourceCoordinator:lambda$notifyCheckpointComplete$8) - Marking checkpoint 14 as completed for source Source: page_log[1].
2025-08-11 15:40:00 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:createPendingCheckpoint) - Triggering checkpoint 15 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1754898000344 for job 6bed03ec47291c6cbc650442810cac0f.
2025-08-11 15:40:00 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:logCheckpointInfo) - Completed checkpoint 15 for job 6bed03ec47291c6cbc650442810cac0f (18236 bytes, checkpointDuration=3 ms, finalizationTime=0 ms).
2025-08-11 15:40:00 INFO (org.apache.flink.runtime.source.coordinator.SourceCoordinator:lambda$notifyCheckpointComplete$8) - Marking checkpoint 15 as completed for source Source: page_log[1].
2025-08-11 15:40:05 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:createPendingCheckpoint) - Triggering checkpoint 16 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1754898005343 for job 6bed03ec47291c6cbc650442810cac0f.
2025-08-11 15:40:05 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:logCheckpointInfo) - Completed checkpoint 16 for job 6bed03ec47291c6cbc650442810cac0f (19124 bytes, checkpointDuration=18 ms, finalizationTime=0 ms).
2025-08-11 15:40:05 INFO (org.apache.flink.runtime.source.coordinator.SourceCoordinator:lambda$notifyCheckpointComplete$8) - Marking checkpoint 16 as completed for source Source: page_log[1].
2025-08-11 15:40:06 INFO (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:onSuccess) - [Consumer clientId=dws_traffic_source_keyword_page_view_window-3, groupId=dws_traffic_source_keyword_page_view_window] Discovered group coordinator node3:9092 (id: 2147483644 rack: null)
2025-08-11 15:40:06 INFO (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:onSuccess) - [Consumer clientId=dws_traffic_source_keyword_page_view_window-2, groupId=dws_traffic_source_keyword_page_view_window] Discovered group coordinator node3:9092 (id: 2147483644 rack: null)
2025-08-11 15:40:06 INFO (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:onSuccess) - [Consumer clientId=dws_traffic_source_keyword_page_view_window-1, groupId=dws_traffic_source_keyword_page_view_window] Discovered group coordinator node3:9092 (id: 2147483644 rack: null)
2025-08-11 15:40:06 INFO (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:onSuccess) - [Consumer clientId=dws_traffic_source_keyword_page_view_window-0, groupId=dws_traffic_source_keyword_page_view_window] Discovered group coordinator node3:9092 (id: 2147483644 rack: null)
2025-08-11 15:40:10 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:createPendingCheckpoint) - Triggering checkpoint 17 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1754898010338 for job 6bed03ec47291c6cbc650442810cac0f.
2025-08-11 15:40:10 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:logCheckpointInfo) - Completed checkpoint 17 for job 6bed03ec47291c6cbc650442810cac0f (19628 bytes, checkpointDuration=4 ms, finalizationTime=0 ms).
2025-08-11 15:40:10 INFO (org.apache.flink.runtime.source.coordinator.SourceCoordinator:lambda$notifyCheckpointComplete$8) - Marking checkpoint 17 as completed for source Source: page_log[1].
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:) - init RecordBuffer capacity 4086, count 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:) - init RecordBuffer capacity 4086, count 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:) - init RecordBuffer capacity 4086, count 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:) - init RecordBuffer capacity 4086, count 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:startBufferData) - start buffer data, read queue size 0, write queue size 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:startBufferData) - start buffer data, read queue size 0, write queue size 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:startBufferData) - start buffer data, read queue size 0, write queue size 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.RecordBuffer:startBufferData) - start buffer data, read queue size 0, write queue size 4
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:startLoad) - table dws_traffic_source_keyword_page_view_window stream load started for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_3_18_e62f4109-231b-4c85-847f-7e0073a0134f on host node1:7030
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:startLoad) - table dws_traffic_source_keyword_page_view_window stream load started for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_2_18_1c6825f3-3c23-40db-832b-7b1464dcc1a1 on host node1:7030
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:startLoad) - table dws_traffic_source_keyword_page_view_window stream load started for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_1_18_181476b9-4077-4226-a503-716a7f5bad6e on host node1:7030
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:startLoad) - table dws_traffic_source_keyword_page_view_window stream load started for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_0_18_1c2294df-977c-4946-afbe-28ec2d963a07 on host node1:7030
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:lambda$startLoad$0) - table dws_traffic_source_keyword_page_view_window start execute load
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:lambda$startLoad$0) - table dws_traffic_source_keyword_page_view_window start execute load
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:lambda$startLoad$0) - table dws_traffic_source_keyword_page_view_window start execute load
2025-08-11 15:40:12 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:lambda$startLoad$0) - table dws_traffic_source_keyword_page_view_window start execute load
2025-08-11 15:40:15 INFO (org.apache.flink.runtime.checkpoint.CheckpointCoordinator:createPendingCheckpoint) - Triggering checkpoint 18 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1754898015336 for job 6bed03ec47291c6cbc650442810cac0f.
2025-08-11 15:40:15 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:stopLoad) - table dws_traffic_source_keyword_page_view_window stream load stopped for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_3_18_9f83c5eb-2897-4d88-b6c4-70355937c44d on host node1:7030
2025-08-11 15:40:15 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:stopLoad) - table dws_traffic_source_keyword_page_view_window stream load stopped for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_1_18_08480a49-ceb5-4d21-9880-281f8f96a0c8 on host node1:7030
2025-08-11 15:40:15 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:stopLoad) - table dws_traffic_source_keyword_page_view_window stream load stopped for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_0_18_d0ec1715-512b-4f55-a572-ed7903cc6af5 on host node1:7030
2025-08-11 15:40:15 INFO (org.apache.doris.flink.sink.writer.DorisStreamLoad:stopLoad) - table dws_traffic_source_keyword_page_view_window stream load stopped for _gmall2024_realtime_dws_traffic_source_keyword_page_view_window_2_18_3a45eb69-492d-4d41-8bf6-ad0145223fa1 on host node1:7030
