Flink中能否直接新建一个sql作业，读mysql中的表然后把结果数据写入到hologres中？

选择创建临时表的方式来导入，新建一个流式作业，然后创建两个mysql的临时表，一个holo的临时表，最后经过join通过insert into方式导入holo表。创建mysql的临时表的方式：
CREATE TEMPORARY TABLE mysql_table (
user_id bigint not null,
status_sort varchar(50) not null,
primary key(user_id) not enforced
) WITH (
'connector' = 'mysql',
'hostname' = 'rm-**s.com',
'port' = '3306',
'username' = 'root',
'password' = '*',
'database-name' = '*',
'table-name' = '**'
);
创建holo的临时表的方式：
CREATE TEMPORARY TABLE IF NOT EXISTS holo_table(
id int,
name varchar,
age int,
PRIMARY KEY(id) NOT ENFORCED
)WITH(
'connector' = 'hologres',
'dbname' = 'mysql_db', --Hologres的数据库名称
'tablename' = 'public.table_test', --Hologres用于接收数据的表名称
'username' = '', --当前阿里云账号的AccessKey ID
'password' = '', --当前阿里云账号的AccessKey Secret
'endpoint' = 'hgpostcn-cn*ncs.com:80', --当前Hologres实例VPC网络的Endpoint
'jdbcretrycount' = '1', --连接故障时的重试次数
'partitionrouter' = 'true', --是否写入分区表
'createparttable' = 'true', --是否自动创建分区
'mutatetype' = 'insertorignore' --数据写入模式
); 此回答整理自钉群“实时计算Flink产品交流群”