foreachPartition 报错

Question

这段代码

administrativeRanksInfoDF.orderBy(administrativeRanksDF.col("administrative_id")).cache()
administrativeRanksInfoDF.foreachPartition(partition => {
  partition.foreach(line => { //这一行报错
    println(line)
  })
})

执行报错，如下：
Error:(58, 9) value foreach is not a member of Object
p.foreach(t=>{

Answer 1

Michael_PK 2019-02-22 13:24:26

你先确认foreach是不是partition能点出来的方法，根据ide的提醒来写。上课的代码就参考git上的原来拷进来对比下

• 提问者 花开北海 #1

  idea 没有报错，执行就报错

• Michael_PK 回复 提问者 花开北海 #2

  这么看我也很难看得出来里面的结构，你再报错的地方打个断电进去，看看到底是哪个部分导致

• qq_海是倒过来的天_21 #3

  老哥，这个问题你解决了吗?