मैं स्पार्क स्टैंडअलोन क्लस्टर चला रहा हूं और एप्लिकेशन जमा करने पर, स्पार्क ड्राइवर निम्न त्रुटि से रोकता है।स्पार्क वर्कर नोड स्वचालित रूप से बंद हो जाता है
16/01/12 23:26:14 INFO Worker: Asked to kill executor app-20160112232613-0012/0
16/01/12 23:26:14 INFO ExecutorRunner: Runner thread for executor app-20160112232613-0012/0 interrupted
16/01/12 23:26:14 INFO ExecutorRunner: Killing process!
16/01/12 23:26:14 ERROR FileAppender: Error writing stream to file /spark/spark-1.4.1/work/app-20160112232613-0012/0/stderr
java.io.IOException: Stream closed
at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170)
at java.io.BufferedInputStream.read1(BufferedInputStream.java:283)
at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
at java.io.FilterInputStream.read(FilterInputStream.java:107)
at org.apache.spark.util.logging.FileAppender.appendStreamToFile(FileAppender.scala:70)
at org.apache.spark.util.logging.FileAppender$$anon$1$$anonfun$run$1.apply$mcV$sp(FileAppender.scala:39)
at org.apache.spark.util.logging.FileAppender$$anon$1$$anonfun$run$1.apply(FileAppender.scala:39)
at org.apache.spark.util.logging.FileAppender$$anon$1$$anonfun$run$1.apply(FileAppender.scala:39)
at org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1772)
at org.apache.spark.util.logging.FileAppender$$anon$1.run(FileAppender.scala:38)
16/01/12 23:26:14 INFO Worker: Executor app-20160112232613-0012/0 finished with state KILLED exitStatus 143
16/01/12 23:26:14 INFO Worker: Cleaning up local directories for application app-20160112232613-0012
मैं स्पार्क और इसकी प्रसंस्करण के लिए नौसिखिया हूं। कृपया मुझे इसमें मदद करें।
क्या आपने इस '/ स्पार्क/स्पार्क-1.4.1/कार्य/ऐप-20160112232613-0012/0/stderr' फ़ाइल के लिए एक्सेस अनुमतियां जांच ली हैं? वैसे भी यह केवल एकमात्र मुद्दा नहीं हो सकता है (क्यों कार्यकर्ता पहले स्थान पर निष्पादक को मारता है?)। –
क्या आप एडब्ल्यूएस पर काम कर रहे हैं? – Rami
@ डेविडपुरा: हां इसमें सभी अधिकार हैं और मैं रूट उपयोगकर्ता के रूप में निष्पादित कर रहा हूं। क्या यह मेरे जार को निष्पादन के लिए नहीं ले सकता है? – Poppy