spark编程中使用foreachPartition的方法里的代码不执行

Question

使用foreachPartition的时候发现，除println能正常打印外，其他的代码都没有执行，请大家们分析一下
foreachPartition为什么不执行其他代码呢？代码如下：

 data.foreachPartition(row=>{
      LogUtils.log.info("["+label+"]=" +"["+TaskContext.getPartitionId+"]")
      LogUtils.print("["+label+"]=" +"["+TaskContext.getPartitionId+"]")
      val mysqlUtils = new MysqlUtils(mysqlUrl, mysqlUser, mysqlPwd)
        mysqlUtils.connect()
        mysqlUtils.prePareSql(label,schema)
        var count = 0
        try{
          row.foreach(
            line=>{
              LogUtils.print("["+label+"]=" +"["+TaskContext.getPartitionId+"]"+line.get(0))
              LogUtils.log.info("["+label+"]=" +"["+TaskContext.getPartitionId+"]"+line.get(0))
              mysqlUtils.saveWideTable(label,schema,line)
              count = count+1
            }
          )
          mysqlUtils.saveRptTable(label,count,TaskContext.getPartitionId)
        }catch {
          case e: Exception => {
            e.printStackTrace()
            mysqlUtils.rollback()
            LogUtils.log.error(e.getMessage)
          }
        } finally {
          mysqlUtils.commit()
          mysqlUtils.disConnect()
        }
      })

Answer 1

你好，我是有问必答小助手，非常抱歉，本次您提出的有问必答问题，技术专家团超时未为您做出解答

本次提问扣除的有问必答次数，将会以问答VIP体验卡（1次有问必答机会、商城购买实体图书享受95折优惠）的形式为您补发到账户。

​​​​因为有问必答VIP体验卡有效期仅有1天，您在需要使用的时候【私信】联系我，我会为您补发。