2015-01-08 103 views
-1

我在java中使用spark。我想用sppark工作的服務器,爲了這個,我試圖按照這樣的:Spark作業服務器

'Clone Ooyala's Spark Job Server 
$ git clone https://github.com/ooyala/spark-jobserver 
$ cd spark-jobserver 

Publish it to local repository and run it 
$ sbt publish-local 
$ sbt 
> re-start 

Create the context that will be shared 
curl -X POST 'localhost:8090/contexts/users-context' 
curl 'localhost:8090/contexts' 

我使用爲例在作業服務器測試: 捲曲--data二進制@作業 - 服務器 - 測試/目標/任務服務器的測試-0.4.1.jar本地主機:8090 /瓶/測試

curl 'localhost:8090/jars' 

curl -d "input.string = a b c a b see" 'localhost:8090/jobs?  
appName=test&classPath=spark.jobserver.WordCountExample' 


Execute the job : 
curl localhost:8090/jobs/<id-job>' 

和它的作品,並顯示結果。我如何寫一個Java作業可以提交到星火作業服務器」?

謝謝。

+0

所以實際的問題是「怎麼我寫的,可以提交到星火作業服務器的Java工作」更好的是混凝土 - >您可以更新問題 – maasg

+0

好的,謝謝你... –

+0

我的意思是所有的部署過程 - 這與被問到的問題無關。 – maasg

回答

相關問題