开发者社区 > 大数据与机器学习 > 人工智能平台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 120 0
0 条回答
写回答
取消 提交回答

相关产品

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

    热门文章

    相关电子书

    更多
    Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
    MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
    消息队列kafka介绍 立即下载