Произошла следующая ошибка Все ресурсы Maven упакованы в jar-файл, запустите время, сообщили о следующих ошибках, я только начал учиться, кто знает, как научить, спасибо
[b]Для написания программы Spark используйте Java, код следующий:[/b] [code]import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaRDD; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.api.java.function.Function;
public class SimpleApp { public static void main(String[] args) { SparkConf conf = new SparkConf().setAppName("wordCount").setMaster("local"); JavaSparkContext sc = new JavaSparkContext(conf); JavaRDD input = sc.textFile("/bigdata/softwares/spark-2.1.0-bin-hadoop2.7/testdata/a.txt"); System.out.println(); Long bCount = input.filter(new Function(){ public Boolean call(String s){return s.contains("yes");} }).count(); Long cCount = input.filter(new Function(){ public Boolean call(String s){return s.contains("ywq");} }).count(); System.out.println("yes:"+bCount+" ywq:"+cCount+" all:"); // sc.stop(); } } [/code] [b]Помимо следующего:[/b] [code]
org.apache.spark spark-core_2.11 2.1.0
org.apache.maven.plugins maven-shade-plugin 2.3
package
shade
[/code] [b]Произошла следующая ошибка[/b] [b]Все ресурсы Maven упакованы в jar-файл, запустите время, сообщили о следующих ошибках, я только начал учиться, кто знает, как научить, спасибо[/b] [img]https://i.sstatic.net/l2FXq.png[/img]