具体错误为:
Exception in thread "main" com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'akka.remote.log-sent-messages'
        at com.typesafe.config.impl.SimpleConfig.findKey(SimpleConfig.java:126)
        at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:146)
        at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:151)
        at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:151)
        at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:119)
        at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:157)
        at com.typesafe.config.impl.SimpleConfig.getBoolean(SimpleConfig.java:167)
        at akka.remote.RemoteSettings.<init>(RemoteSettings.scala:19)
        at akka.remote.RemoteActorRefProvider.<init>(RemoteActorRefProvider.scala:32)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
        at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
        at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3$$anonfun$apply$1.apply(DynamicAccess.scala:108)
        at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3$$anonfun$apply$1.apply(DynamicAccess.scala:105)
        at akka.actor.DynamicAccess$class.withErrorHandling(DynamicAccess.scala:72)
        at akka.actor.ReflectiveDynamicAccess.withErrorHandling(DynamicAccess.scala:90)
        at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:105)
        at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:102)
        at scala.Either.fold(Either.scala:96)
        at akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:102)
        at akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:549)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
        at spark.util.AkkaUtils$.createActorSystem(AkkaUtils.scala:51)
        at spark.SparkEnv$.createFromSystemProperties(SparkEnv.scala:81)
        at spark.SparkContext.<init>(SparkContext.scala:79)
        at spark.streaming.StreamingContext$.createNewSparkContext(StreamingContext.scala:493)
        at spark.streaming.StreamingContext.<init>(StreamingContext.scala:67)
        at spark.streaming.api.java.JavaStreamingContext.<init>(JavaStreamingContext.scala:56)
写完后打成jar运行,程序如下
 public static void main(String[] args) {
System.out.println(args[0]);
//System.setProperty("akka.remote.log-received-messages", "off");
if (args.length < 2) {
System.err.println("Usage: NetworkWordCount <master> <imageindex>\n"
+ "In local mode, <master> should be 'local[n]' with n > 1");
System.exit(1);
}
JavaStreamingContext ssc = new JavaStreamingContext(args[0],"ImageCut", new Duration(1000), 
System.getenv("SPARK_HOME"), "/data/realtime/imagecut/imagecutspark.jar" ); JavaDStream<String> lines = ssc.textFileStream(args[1]);
lines.map(new Function<String, Void>(){ private static final long serialVersionUID = 1L; @Override
public Void call(String imagepath) throws Exception {
Runtime.getRuntime().exec("sh /data/realtime/imagecut/imagecut.sh "+ imagepath);
return null;
}   
});

ssc.start();
}