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
和使用的配置來獲得該定製參數。
感謝您的回覆,我明白多次提交jar會導致新的工作,請參閱我的更新 – user3230153
問題看起來問題已解決? – jagsr