MySQLデータベースにアクセスしてテーブルを取得しました。 それまですべてがうまくいっています。ChangeFileModeByMaskエラー(5):アクセスが拒否されました
テキストまたはその他の形式でレコードを保存しようとしています。エラーが発生しました。 終了コード例外終了コード= 1: 'マスクでファイルモードを変更するエラー'(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時十分19秒エラーエグゼキュータ:段階におけるタスク0.0の例外2.0 (TID 2)ExitCodeException EXITCODE = 1:ChangeFileModeByMaskエラー(5): アクセスが拒否されました。
org.apache.hadoopでorg.apache.hadoop.util.Shell.run(Shell.java:479)でorg.apache.hadoop.util.Shell.runCommand(Shell.java:582)で.util.Shell $ ShellCommandExecutor.execute(Shell.java:773) (org.apache.hadoop.util.Shell.execCommand(Shell.java:866)) org.apache.hadoop.util.Shell.execCommand(Shell .javaファイル: org.apache.hadoop.fs.RawLocalFileSystem $ LocalFSFileOutputStreamで org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:733) で849)(RawLocalFileSystem.java:225) で。 org.apache.hadoop.fs.RawLocalFileSystem $ LocalFSFileOutputStream。(RawLocalFileSystem.java:209 ) でorg.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:307) でorg.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:296) org.apacheました。 hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:328)
あなたは別の場所で書いてみましたか? –
ええと...私はそれを試みたが運がない –