问题一:Flink子账号设置了AliyunStreamFullAcces权限为什么不能设置报警通知?
Flink子账号设置了AliyunStreamFullAcces权限为什么不能设置报警通知?
参考答案:
该权限并不一定包括设置报警通知的权限,"aliyunstreamfullaccess"权限主要针对阿里云流计算的相关资源和操作提供完全访问权限。 https://help.aliyun.com/zh/ram/use-cases/use-ram-to-manage-permissions-of-o-and-m-engineers?spm=a2c4g.11186623.0.i8#:~:text=AliyunCloudMonitorFullAccess
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/658097
问题二:Flink中Tm的日志默认是多少行?
Flink中Tm的日志默认是多少行?
参考答案:
Flink的Job Manager和Task Managers的运行日志,默认每页显示大约8000~9000行,支持日志分页功能。这一设定旨在帮助用户基本排查错误情况,如需查看更多日志,可切换日志查看页码。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/621325
问题三:Flink中能否直接新建一个sql作业,读mysql中的表然后把结果数据写入到hologres中?
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' --数据写入模式
);
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/624518
问题四:Flink这种咋回事?
Flink这种咋回事? 8个并行 7个马上跑完 剩下一个慢慢跑
参考答案:
source并行度不匹配吧,例如mysql的binlog只能一个并行度,多了也是finsh
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/659041
问题五:Flink这种如何处理 只能选择关闭这个算子?
Flink这种如何处理 只能选择关闭这个算子?
参考答案:
红色代表任务繁忙,可以等待一会。左边有个算子反压了
关于本问题的更多回答可点击进行查看: