问题一:Flink这个是权限不够吗?
Flink这个是权限不够吗?
参考回答:
是的,权限不够。这是关于权限的文档
https://help.aliyun.com/zh/flink/user-guide/permission-management/?spm=a2c4g.11186623.0.i8 这是关于项目空间的权限文档
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610248
问题二:Flink报这个错误,啥原因?
Flink报这个错误,啥原因?
参考回答:
应该是并发度太大,运行一段时间后,由于其他原因写入流量异常导致任务停止。目前推荐的解决方案就是减少并发度。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610247
问题三:Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?
Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?
参考回答:
滑动窗口,需要有个时间参数来定义时间,而且字段类型一般都是timestamp。Eventtime 开窗要在 Souce DDL 上进行的 watermark 定义 https://help.aliyun.com/zh/flink/developer-reference/hop?spm=a2c4g.11186623.0.0.3ef35284lIylGu
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610232
问题四:用社区版本flink-doris-connector-1.17-1.5.2.jar提示错误,怎么办?
用社区版本flink-doris-connector-1.17-1.5.2.jar提示错误,怎么办?
参考回答:
阿里flink文档中并没有关于doriscatalog的内容,不过尝试下面这个方法
在Flink中创建DorisCatalog:这一步需要编写一些Java代码来实现。需要创建一个继承自org.apache.flink.table.factories.CatalogFactory的类,并在该类的createCatalog()方法中实现对Doris的连接和元数据的获取。
注册DorisCatalog:在Flink的配置文件中,我们需要将刚刚创建的DorisCatalog注册进去。这样,Flink就可以通过这个Catalog来访问Doris中的数据了。
在这里创建自定义doris的catalog。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610230
问题五:flink任务启动后一直在重启,怎么解决?
flink任务启动后一直在重启,怎么解决?
参考回答:
报错原因应该是字段大小写不一致 insert into holo-ods
.ods
.ctm_ci_cinema
select 大写字段名 as 小写字段名, ... from ...
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610222