seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

sync data speed is too low, please help me

Open zhangtao106 opened this issue 1 year ago • 4 comments

Code of Conduct

Search before asking

  • [X] I had searched in the issues and found no similar issues.

Describe the proposal

I was synchronized data from DRDS to Doris, my query range is “id < 50000000”, but total data less than 50000000, when i synchorized, that speed was very slow! less than datax much .
 my data  in DRDS has 42  cloumns, and this is my conf:

env { checkpoint.interval = 10000 job.mode = "batch" } source{ Jdbc { url = "jdbc:mysql://x.x.x.x:3306/pp_data_ds?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&socketTimeout=6000000&waitTimeout=60000&autoReconnect=true&rewriteBatchedStatements=true&connectTimeout=60000" driver = "com.mysql.cj.jdbc.Driver" connection_check_timeout_sec = 100 user = "user_ro" password = "******" query = "select province_name`, ... from table_data where id >0 and id < 50000000"

}

}

sink { Doris { fenodes = "x.x.x.x:8030" username = test password = "*******" database = "test" table = "td_sub_sms_port_bk" sink.label-prefix = "test-batch" sink.enable-2pc = "true" sink.enable-delete = "true" doris.config { format = "json" read_json_by_line = "true" } } }`

when I submit job config into cluster, log info is update slow , aaaa

Task list

env { checkpoint.interval = 10000 job.mode = "batch" } source{ Jdbc { url = "jdbc:mysql://x.x.x.x:3306/pp_data_ds?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&socketTimeout=6000000&waitTimeout=60000&autoReconnect=true&rewriteBatchedStatements=true&connectTimeout=60000" driver = "com.mysql.cj.jdbc.Driver" connection_check_timeout_sec = 100 user = "user_ro" password = "******" query = "select province_name, ... from table_data where id >0 and id < 50000000"

}

}

sink { Doris { fenodes = "x.x.x.x:8030" username = test password = "*******" database = "test" table = "td_sub_sms_port_bk" sink.label-prefix = "test-batch" sink.enable-2pc = "true" sink.enable-delete = "true" doris.config { format = "json" read_json_by_line = "true" } } }

Are you willing to submit PR?

  • [X] Yes I am willing to submit a PR!

zhangtao106 avatar Jul 08 '24 08:07 zhangtao106

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

github-actions[bot] avatar Aug 08 '24 00:08 github-actions[bot]

I can fix

panpan2019 avatar Aug 09 '24 03:08 panpan2019

I encountered the same problem, have you solved it yet

Anoye avatar Oct 15 '24 09:10 Anoye

I can fix

how? more specific please.thanks a lot

richardblabin avatar Oct 15 '24 10:10 richardblabin

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

github-actions[bot] avatar Jul 12 '25 00:07 github-actions[bot]

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.

github-actions[bot] avatar Jul 20 '25 00:07 github-actions[bot]