我想将我的rdd持久化到mysql数据库表中。我使用了一个map函数来迭代rdd，并将每个元组传递到我的函数中，在那里我进行持久化。这里我想把我的工作并行化为主节点和从节点。
但是它不能正常工作，也不能调用使数据库持久化的函数。
如果我使用collect（）例如 courseSet.collect().map(m => sendCourseInfo(m)) 而不是 courseSet.map(m => sendCourseInfo(m)) 这很管用。
我不想在这里使用collect（）。
我在很多文章中都找过这个，但都找不出来。有谁能帮我解决这个问题吗。
下面是我的密码，

.....
  x.toString().split(",")(1),
  x.toString().split(",")(2),
  x.toString().split(",")(3)))

 courseSet.map(m => sendCourseInfo(m))
}

def sendCourseInfo(courseData: (Int, String, String, String)): Unit = {
    try {
      DatabaseUtil.setJDBCConfiguration()

      val jdbcConnection: java.sql.Connection = DatabaseUtil.getConnection

      val statement = "{call insert_course (?,?,?,?)}"
      val callableStatement = jdbcConnection.prepareCall(statement)
      callableStatement.setInt(1, courseData._1)
      callableStatement.setString(2, courseData._2)
      callableStatement.setString(3, courseData._3)
      callableStatement.setString(4, courseData._4)

      callableStatement.executeUpdate
    } catch {
      case e: SQLException => println(e.getStackTrace)
    }
}