开发者社区 > 大数据与机器学习 > 人工智能平台PAI > 正文

如图,在机器学习PAI的pyflink读取kafka数据, 一直报这个错怎么回事

在机器学习PAI的pyflink读取kafka数据,使用TableSourceStream Op转成alink的op,一直报这个错,大家有没有遇到,怎么解决呢?kafka的connector包已正常导入
4474125657433a0fbbdb39edc8cf046e.jpg
插件下载了的,我改了pyalink env.py的一行代码,把use_old_planner改为use_blink_planner,就跑成功了,有个疑问use_old_planner已经废弃了,我们源码是不是也应该更新下
767a95b99248f3cc018538b7ced72499.jpg

展开
收起
乐天香橙派 2023-10-06 16:05:20 175 0
0 条回答
写回答
取消 提交回答

人工智能平台 PAI(Platform for AI,原机器学习平台PAI)是面向开发者和企业的机器学习/深度学习工程平台,提供包含数据标注、模型构建、模型训练、模型部署、推理优化在内的AI开发全链路服务,内置140+种优化算法,具备丰富的行业场景插件,为用户提供低门槛、高性能的云原生AI工程化能力。

相关产品

  • 人工智能平台 PAI
  • 热门讨论

    热门文章

    相关电子书

    更多
    大规模机器学习在蚂蚁+阿里的应用 立即下载
    阿里巴巴机器学习平台AI 立即下载
    机器学习及人机交互实战 立即下载