SnappyData REST提交作业

Question

我正在尝试使用REST提交快速作业。

• 我们已经能够使用snappy-作业提交命令行工具提交SnappyJob。
• 我找不到任何文档如何通过REST来做同样的事情。
• 我发现在论坛中提到的某个地方，SnappyData正在使用星星之火j观测者REST。 您能指出文档/用户指南如何做到这一点吗？

Answer 1

Snappydata内部使用火花-j观察者来提交作业。因此，在Snappydata的牵头节点上可以访问所有星星之火的REST。

您可以参考这里所有的星星之火API：https://github.com/SnappyDataInc/spark-jobserver#api。

下面是一些有用的curl命令来进一步澄清它：

• 在作业服务器上部署应用程序jar：

curl --data-binary @/path/to/applicaton.jar localhost:8090/jars/testApp

testApp是将用于提交作业的作业服务器应用程序的名称。

• 创建上下文：

curl -X POST "localhost:8090/contexts/testSnappyContext?context-factory=org.apache.spark.sql.SnappySessionFactory"

testSnappyContext是将用于提交作业的上下文的名称。

另外，请注意，我们在这里传递一个自定义上下文-工厂参数，这是提交快速作业所必需的。

• 提交工作：

curl -d "configKey1=configValue1,configKey2=configValue2" "localhost:8090/jobs?appName=testApp&classPath=com.package.Main&context=testSnappyContext"

com.package.Main是扩展org.apache.spark.sql.SnappySQLJob的类的完全限定名。

• 停止这项工作

curl -X DELETE localhost:8090/jobs/bfed84a1-0b06-47ca-81a7-9b8defb51e38

bfed84a1-0b06-47ca-81a7-9b8defb51e38是您将在作业提交请求的响应中获得的作业id。

• 停止上下文

curl -X DELETE localhost:8090/contexts/testSnappyContext

• 卸载应用程序jar

snappydata使用的作业服务器版本没有公开用于卸载jar的jar API。但是，部署任何具有相同应用名称的jar (在我们的示例中是testApp)将覆盖同一个应用程序先前部署的jar。