应用程序提交到spark集群中 一般是怎么做的
解决方案 »
- OpenStack两岁生日,你想对他说点什么呢?
- 从苹果iPhone6上市,解读云存储产业生态圈
- Hive提交任务过程十分的慢的问题
- 问一下EC2使用量比如磁盘读写次数之类的东西,在哪看呢?
- configure: error: png.h not found.
- 惠普dl580g7内存扩容黑屏
- spark的rdd问题求助
- 安装redmine和mysql后,redmine容器启动后就退出,如何处理?
- Spark中如何将javaDStream<String>转化为JavaPairDstream ?
- 如何知道一个正在运行的容器是否使用了-d参数
- java提交spark应用程序到集群中
- apark中的数据分析算法有哪些?
参见官方文档
String tmp = "/home/hadoop/spark-spring-0.0.1-SNAPSHOT.jar";
args = new String[]{
"--master","spark://master:7077",
"--deploy-mode","cluster",
"--name","test java submit job to spark",
"--class","br.com.spark.JavaWordCount",
"--executor-memory","512m",
tmp
};
SparkSubmit.main(args);
但是 我没有跑通,这是在我本地开发环境提交的;