2017-10-10 47 views
1

SnappyData文檔就如何提交一個罐子到羣集的例子:SnappyData提交罐子參數集羣

https://snappydatainc.github.io/snappydata/howto/run_spark_job_inside_cluster/

但是,如果我需要與同一類CreatePartitionedRowTable 提交罐子什麼多次,但有不同的參數,說不同的後綴追加到創建的表名稱,我該怎麼做?

UPDATE:

更確切地說,說我要提交使用不同的參數罐子時,我提交的罐子,像這樣

bin/snappy-job.sh submit 
    --app-name CreatePartitionedRowTable 
    --class org.apache.spark.examples.snappydata.CreatePartitionedRowTable 
    --app-jar examples/jars/quickstart.jar 
    --lead localhost:8090 
    --CustomeParam suffix 

附加

--CustomeParam suffix 

將被傳遞給作業,並且代碼可以獲取此參數後綴,並將後綴附加到要創建的表名,以便我不必每次都修改我的代碼我希望提交具有不同後綴的jar。

更新2:

我只是通過實例去,發現了一個實例: https://github.com/SnappyDataInc/snappydata/blob/master/examples/src/main/scala/org/apache/spark/examples/snappydata/CreateColumnTable.scala

所以基本上像這樣運行:

* bin/snappy-job.sh submit 
* --app-name CreateColumnTable 
* --class org.apache.spark.examples.snappydata.CreateColumnTable 
* --app-jar examples/jars/quickstart.jar 
* --lead [leadHost:port] 
* --conf data_resource_folder=../../quickstart/src/main/resources 

和使用的配置來獲得該定製參數。

回答

1

每次你用snappy-job.sh提交你的應用jar時,它都會創建一個新的Job並運行它。它可以是具有不同內容的相同罐子。你是否看到任何異常或修改的類(CreatePartitionedRowTable)沒有被拾取?

+0

感謝您的回覆,我明白多次提交jar會導致新的工作,請參閱我的更新 – user3230153

+0

問題看起來問題已解決? – jagsr