maben996 commented on issue #19461:
URL: https://github.com/apache/doris/issues/19461#issuecomment-1613533119
> Sender is gone means that the streamload http connection timed out, and
the client canceled the connection. You can confirm whether it is an error
reported by the network timeout
flink sql cdc mongodb2doris, doris version
1.2.4，配置了'sink.properties.timeout' = '7200'依然报错
```sql
DORIS_SINK param:
'connector' = 'doris',
'fenodes' = 'xxxxx:8030',
'table.identifier' = 'xxxx.xxxxx',
'username' = 'xxxx',
'password' = 'xxxxxx',
'sink.enable-delete' = 'false',
'sink.enable-2pc' = 'false',
'sink.properties.timeout' = '7200',
'doris.request.retries' = '3',
'doris.request.connect.timeout.ms' = '180000',
'doris.request.read.timeout.ms' = '180000',
'sink.label-prefix'='mongo2doris_compliance_msg_08'
```
```shell
W0630 00:19:39.061848 29103 stream_load_executor.cpp:233] 2PC commit
transaction failed, errmsg=[ANALYSIS_ERROR]errCode = 2, detailMessage =
transaction [55697] is already visible, not pre-committed.
W0630 00:21:21.691363 29103 stream_load_executor.cpp:233] 2PC commit
transaction failed, errmsg=[ANALYSIS_ERROR]errCode = 2, detailMessage =
transaction [55700] is already visible, not pre-committed.
W0630 00:45:06.584319 28656 scanner_scheduler.cpp:256] Scan thread read
VScanner failed: [INTERNAL_ERROR]cancelled: sender is gone
W0630 00:45:06.584388 28558 fragment_mgr.cpp:118]
query_id=164826560afd9a8e-f16b8300eb1b9489,
instance_id=164826560afd9a8e-f16b8300eb1b948a meet error status
[INTERNAL_ERROR]cancelled: sender is gone
W0630 00:45:06.584437 28558 fragment_mgr.cpp:405] report error status:
[INTERNAL_ERROR]cancelled: sender is gone to coordinator:
TNetworkAddress(hostname=10.1.64.9, port=9020), query id:
164826560afd9a8e-f16b8300eb1b9489, instance id:
164826560afd9a8e-f16b8300eb1b948a
W0630 00:45:06.584941 28558 fragment_mgr.cpp:261] Got error while opening
fragment 164826560afd9a8e-f16b8300eb1b948a, query id:
164826560afd9a8e-f16b8300eb1b9489: [INTERNAL_ERROR]cancelled: sender is gone
W0630 00:45:06.585201 28558 tablet_sink.cpp:156] cancel node channel
VNodeChannel[233525-10005], load_id=164826560afd9a8e-f16b8300eb1b9489,
txn_id=55910, node=10.1.64.14:8060, error message: [INTERNAL_ERROR]cancelled:
sender is gone
W0630 00:45:06.585237 28558 tablet_sink.cpp:156] cancel node channel
VNodeChannel[233525-10004], load_id=164826560afd9a8e-f16b8300eb1b9489,
txn_id=55910, node=10.1.64.13:8060, error message: [INTERNAL_ERROR]cancelled:
sender is gone
W0630 00:45:06.585253 28558 tablet_sink.cpp:156] cancel node channel
VNodeChannel[233525-10003], load_id=164826560afd9a8e-f16b8300eb1b9489,
txn_id=55910, node=10.1.64.12:8060, error message: [INTERNAL_ERROR]cancelled:
sender is gone
W0630 00:45:06.585364 28558 stream_load_executor.cpp:80] fragment execute
failed, query_id=164826560afd9a8e-f16b8300eb1b9489,
err_msg=[INTERNAL_ERROR]cancelled: sender is gone,
id=164826560afd9a8e-f16b8300eb1b9489, job_id=-1, txn_id=55910,
label=mongo2doris_compliance_msg_05_0_1688057019151, elapse(s)=87
```
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
