java调用nebulae-exchange导入mysql数据的方式

提问参考模版:

  • nebula 版本:v3.2.0

  • 部署方式: 单机

  • 安装方式: Docker

  • 是否为线上版本: N

  • 问题的具体描述:spark运行在远程服务器,当前业务代码如何通过nebula-exchange导入mysql数据,是否有java远程提交spark任务的样例,参考参考 :grinning:

https://github.com/mahmoudparsian/data-algorithms-book/blob/master/misc/how-to-submit-spark-job-to-yarn-from-java-code.md

1 个赞

你可以了解下 SparkLuncher

Launcher for Spark applications. Use this class to start Spark applications programmatically. The class uses a builder pattern to allow clients to configure the Spark application and launch it as a child process.

你好,sparkLauncher需要运行业务代码的服务有spark环境吧,它需要指定sparkHome,但现在spark服务在远程服务器 本地没有。

你的业务代码是要打包跑在服务器上的,可以打包后在服务器上启动,也可以在本地安装一个单机的spark

刚用了一种通过spark Rest的方式提交spark任务,事先我把nebula-exchange_spark_3.0-3.3.0和mysql驱动的jar包上传到了spark环境,任务提交成功了,但是运行的时候提示找不到类。

你是啥模式提交的spark 任务,如果是集群模式,需要每台机器都上传

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。