实时计算 Flink版操作报错合集之遇到报错：Caused by: com.aliyun.odps.tunnel.TunnelException:，该怎么办

问题一：Flink这个是权限不够吗？

Flink这个是权限不够吗？

参考回答：

是的，权限不够。这是关于权限的文档

https://help.aliyun.com/zh/flink/user-guide/permission-management/?spm=a2c4g.11186623.0.i8 这是关于项目空间的权限文档

https://help.aliyun.com/zh/flink/user-guide/grant-permissions-to-an-account?spm=a2c4g.11186623.0.0.3c956054nnQTxR   。

关于本问题的更多回答可点击原文查看：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