[GitHub] [doris] maben996 commented on issue #19461: [Bug] FlinkCDC同步Mysql数据到Doris, [INTERNAL_ERROR]cancelled: sender is gone

["maben996 (via GitHub)" <gi...@apache.org>]

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-unsubscribe@doris.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org