tongchenkeji 发表于:2023-4-10 12:31:110次点击 已关注取消关注 关注 私信 现在是用自定义个broadcastfunction方案吗?用flink-cep-vvr的这[阿里云实时计算 Flink版] 暂停朗读为您朗读 现在是用自定义个broadcastfunction方案吗? 用flink-cep-vvr的这个包,有些类找不到 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 实时计算 Flink版3179
云原生那些事AM 2023-11-27 18:38:59 1 自定义function就差不多了应该,我这儿还弄了其他功能,operator也自定义了。没用过阿里的。 此答案来自钉钉群“【2】Apache Flink China 社区”
HaydenGuoAM 2023-11-27 18:38:59 2 不确定。不过在Flink中,BroadcastFunction可以用来将广播变量发送到Flink任务的所有并行实例中,从而可以让计算更加高效。如果你需要使用BroadcastFunction,可以参考Flink官方文档中的说明。 至于flink-cep-vvr这个包找不到类的问题,可能是由于依赖版本不兼容引起的。你可以尝试排查一下使用的版本是否正确,并且确认是否有所有的依赖项被正确地导入到项目中。另外,你也可以尝试更新一下你的依赖项版本,看看是否能解决问题。如果仍然无法解决问题,可以尝试发工单找阿里云技术支持一起排查。
自定义function就差不多了应该,我这儿还弄了其他功能,operator也自定义了。没用过阿里的。
此答案来自钉钉群“【2】Apache Flink China 社区”
不确定。不过在Flink中,BroadcastFunction可以用来将广播变量发送到Flink任务的所有并行实例中,从而可以让计算更加高效。如果你需要使用BroadcastFunction,可以参考Flink官方文档中的说明。
至于flink-cep-vvr这个包找不到类的问题,可能是由于依赖版本不兼容引起的。你可以尝试排查一下使用的版本是否正确,并且确认是否有所有的依赖项被正确地导入到项目中。另外,你也可以尝试更新一下你的依赖项版本,看看是否能解决问题。如果仍然无法解决问题,可以尝试发工单找阿里云技术支持一起排查。