具體錯誤為：
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();
}
uj5u.com熱心網友回復：
我也碰到這個問題uj5u.com熱心網友回復：
我也遇到了這個問題uj5u.com熱心網友回復：
后來吧akka相關的包給刪掉，不報這錯了，很暴力吧轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/107055.html
標籤：服務器