ChangeFileModeByMask error (5): Access is denied

Question

我访问了 MySQL 数据库并获取了 table。在那之前一切正常。

当我尝试以文本或其他格式保存记录时出现错误 退出代码异常退出代码=1: 'Change File Mode By Mask error' (5): 访问被拒绝。

如有任何帮助，我们将不胜感激。

object jdbcConnect {
 def main(args: Array[String]) {

   val url="jdbc:mysql://127.0.0.1:3306/mydb" 
   val username = "root"
   val password = "token_password"
   Class.forName("com.mysql.jdbc.Driver").newInstance


   //DriverManager.registerDriver(new com.mysql.jdbc.Driver());

   val conf = new SparkConf().setAppName("JDB CRDD").setMaster("local[2]").set("spark.executor.memory", "1g")

    val sc = new SparkContext(conf)
    val myRDD = new JdbcRDD( sc, () => 
    DriverManager.getConnection(url,username,password) ,
  "select s_Id,issue_date from store_details limit ?, ?",
  0, 10, 1, r => r.getString("s_Id") + ", " + r.getString("issue_date"))

   myRDD.foreach(println)
   myRDD.saveAsTextFile("C:/jdbcrddexamplee")

  }
}

错误

17/07/18 11:10:19 ERROR Executor: Exception in task 0.0 in stage 2.0 (TID 2) ExitCodeException exitCode=1: ChangeFileModeByMask error (5): Access is denied.

at org.apache.hadoop.util.Shell.runCommand(Shell.java:582) at org.apache.hadoop.util.Shell.run(Shell.java:479) at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:773) at org.apache.hadoop.util.Shell.execCommand(Shell.java:866) at org.apache.hadoop.util.Shell.execCommand(Shell.java:849) at org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:733) at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.(RawLocalFileSystem.java:225) at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.(RawLocalFileSystem.java:209) at org.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:307) at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:296) at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:328)

Answer 1

好像是权限错误。我的愚蠢...

确保运行以管理员身份进行任何操作。虽然我会建议使用数据框而不是 RDD :D

ChangeFileModeByMask error (5): Access is denied

ChangeFileModeByMask error (5): Access is denied

java

etl

scala

apache-spark