flink table api

求助大佬,可以使用flink table api读取strraocks吗,想要通过table api 进行flink-cdc的数据同步
代码如下,运行显示连接超时呢

public class SelectMysql {
public static void main(String[] args) {
TableEnvironment env = TableEnvironment.create(EnvironmentSettings.newInstance().inStreamingMode().build());
env.executeSql(“CREATE TABLE IF NOT EXISTS mysql_t (\n” +
" table_name varchar(255),\n" +
" datatypes varchar(255)\n" +
“) with (\n” +
" ‘connector’ = ‘starrocks’,\n" +
" ‘jdbc-url’ = ‘’,\n" +
" ‘scan-url’ = ‘’,\n" +
" ‘username’ = ‘’,\n" +
" ‘password’ = ‘’,\n" +
" ‘database-name’ = ‘’,\n" +
" ‘table-name’ = ‘’\n" +
“);”);
Table mysqlT = env.from(“mysql_t”);
mysqlT.select(Expressions.$("*")).execute().print();
}
}

IP和端口都是可以访问的嘛,be的8040端口也需要开放。

都是可访问的哈,可以使用datastream或者dbserver连接呢。
table api可以通过mysql协议读取sr的数据,会不会因为版本太高呢?
flink: 1.19.1
starrocks-connector: 1.2.9-1.18