问题一:Flink topic分配是怎么实现的 没有自定义的吗?
Flink topic分配是怎么实现的 没有自定义的吗?
参考回答:
使用flink自带的,改了下源码那里面的分配算法,但是不理想
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573368
问题二:请问 Flink阿里的 动态加载cep 开源了吗 ?
请问 Flink阿里的 动态加载cep 开源了吗 ?
参考回答:
阿里云的开源大数据团队对 Flink CEP 的实现进行了改进,支持了在 Flink 作业中动态加载规则,并且增强了 Flink CEP SQL 语法。这一改进充分发挥了 Flink 引擎的性能,并在实时风控场景中表现出色。此外,实时计算Flink版也支持通过DataStream作业的方式运行支持规则动态更新的Flink CEP作业,这为实时营销中的反作弊场景提供了有力的支持。
Flink CEP 的未来工作重点还包括扩展动态 CEP 多规则能力到静态场景,以及进一步优化CEP SQL。在阿里云的服务中,动态 CEP 能力已经被集成在最新版本中,极大地简化了风控场景的开发周期。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573367
问题三:请问一下:flinkSQL或pyflink是否有支持整库同步的功能呀?
请问一下:flinkSQL或pyflink是否有支持整库同步的功能呀?
参考回答:
得看对应的数据源connect or实现。 比如说jdbc connector就不支持,cdc connector部分支持。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566855
问题四:Flink网上看到阿里的flink olap改造,这块现在代码有发布出来么?
Flink网上看到阿里的flink olap改造,这块现在代码有发布出来么?
参考回答:
可以通过以下方式了解阿里在这方面的进展:
- 关注官方渠道:查看阿里巴巴集团或阿里云官方网站上的博客、新闻稿和技术文档,这些资料可能会分享他们在 Flink OLAP 领域的研究成果和实践经验。
- 参加社区活动:阿里巴巴的技术专家经常在各种技术会议和研讨会上发表演讲,你可以通过参加这些活动获取第一手信息。
- 加入社区讨论:参与 Apache Flink 的邮件列表、Slack 频道或 Stack Overflow 讨论,与其他开发者交流经验,并询问关于 Flink OLAP 方面的问题。
如果你确实需要使用 Flink 进行 OLAP 分析,可以考虑使用 Apache Flink 社区提供的官方版本,它包含了基本的流处理和批处理功能。同时,也可以研究其他开源 OLAP 工具,如 Druid、ClickHouse 等,看看它们是否能满足你的需求。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573365
问题五:Flink 从kafka中消费到数据到map里每条转换json对象太耗时,有什么好的解决办法吗?
Flink 从kafka中消费到数据到map里每条转换json对象太耗时,繁忙100%,导致source反压,这种情况有什么好的解决办法吗?
参考回答:
map算子并行度调到source的2倍试试
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573364