Search before asking

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

What happened

I try to use jbdc(mysql) to extract data from starrocks. it's a big query, if run the query directly, will get timeout over 300s exception. it's throw by starrocks.

so i want split the query to multiple small query. i add partition_column parameter. but i find the jdbc default split logical add this query filter
abs(md5(<partition_column>)) % <partition_num> = ?
the finial query would be

select * from ( user defined query ) split where abs(md5(<partition_column>)) % <partition_num> = ?

in mysql the result of md5 % <partition_num> is a number, so it can work.

but in starrocks, it can't work. we need use md5sum_numeric function.

SeaTunnel Version

2.3.5

SeaTunnel Config

{

            "password" : "",

            "driver" : "com.mysql.cj.jdbc.Driver",

            "query" : "xxxxxx",

            "connection_check_timeout_sec" : 100,

            "fetch_size" : 10000,

            "partition_column" : "data_day", -- string type

            "result_table_name" : "",

            "plugin_name" : "Jdbc",

            "user" : "xxx",

            "url" : "jdbc:mysql://xxx"

        }

Running Command

rest api to submit job

Error Exception

no exception, and no data readed

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct