问题一:Flink sql将数组炸开,实现hive的explode函数的效果,还有什么其他好的方式?
Flink sql将数组炸开,实现hive的explode函数的效果,除了用cross join的方式以外,还有什么其他好的方式?
参考答案:
UNNEST。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581167
问题二:为什么Flink实时计算的产品支持这么慢?
为什么Flink实时计算的产品支持这么慢?
参考答案:
Flink实时计算的产品支持进展可能受到多方面因素的影响。一方面,Flink作业的优化是一个关键的过程,涉及到作业配置和Flink SQL优化等技术环节。例如,当作业并发较大时,可以在作业的部署详情页签的资源配置中,增加JobManager的资源,提高CPU和内存的大小,以提升处理性能。另一方面,理解Flink实时计算的基本概念以及解决常见问题也非常重要。此外,Flink产品的性能优越性、功能强大性和成本效益也是决定其支持速度的关键因素。因此,如果感觉Flink实时计算的产品支持慢,可以从以上这些方面进行排查和优化。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581166
问题三:Flink这个可以支持多个分隔符嘛?
Flink这个可以支持多个分隔符嘛?lateral table(string_split
参考答案:
两个或多个连续出现的分隔符被视为一个分隔符。
https://help.aliyun.com/zh/flink/developer-reference/string-split?spm=a2c4g.11186623.0.i2
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581165
问题四:Flink的SDK 支持Session任务提交么?
Flink的SDK 支持Session任务提交么?在Demo里面看不到Session集群的测试用例
不是出现上面报错就是这个报错测试官方文档全部SDK,目前能正常查询的只有引擎版本信息。。
参考答案:
Flink的SDK确实支持Session任务提交。在YARN集群上,可以使用yarn-session.sh命令来开辟资源,并配合flink run命令提交任务。此外,对于Standalone集群,提交Flink任务的方式也是使用的Session模式。不仅如此,Flink On Yarn任务提交还支持Per-Job单作业模式和Application应用模式。这些模式为不同的使用场景提供了多样化的选择。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581164
问题五:在Flink我们现在数据库中有新增索引,但是同步任务没有报错,所以可以知道索引这边的变动的影响吗?
在Flink我们现在数据库中有新增索引,但是同步任务没有报错,所以可以知道索引这边的变动的影响吗?
参考答案:
索引变更不会自动同步到下游,应该不会影响数据处理。
关于本问题的更多回答可点击进行查看: