You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by "qwe3144 (via GitHub)" <gi...@apache.org> on 2024/08/22 10:28:23 UTC
[I] Submitting tasks to a K8s environment using Spark plugins yields different results compared to using shell and Spark plugins,even thougth the same command [dolphinscheduler]
qwe3144 opened a new issue, #16505:
URL: https://github.com/apache/dolphinscheduler/issues/16505
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and found no similar issues.
### What happened
shell command as same spark like：
$SPARK_HOME/bin/spark-submit \
--name cluster-model-app \
--verbose \
--master k8s://https://192.168.10.40:6443 \
--deploy-mode cluster \
--conf spark.network.timeout=300 \
--conf spark.executor.instances=2 \
--conf spark.kubernetes.namespace=dev \
--conf spark.kubernetes.container.image.pullPolicy=IfNotPresent \
--conf spark.kubernetes.container.image=hzent/spark:hadoop3.2 \
--conf spark.kubernetes.container.image.pullSecrets=dev-image-secret \
--conf spark.kubernetes.authenticate.driver.serviceAccountName=scheduler \
--conf spark.kubernetes.authenticate.executor.serviceAccountName=scheduler \
--conf "spark.hadoop.fs.s3a.access.key=xxxX" \
--conf spark.kubernetes.executor.deleteOnTermination=true \
--conf "spark.hadoop.fs.s3a.secret.key=xxxx" \
--conf "spark.hadoop.fs.s3a.endpoint=http://minio.xxxx:9000" \
--conf "spark.hadoop.fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem" \
--conf "spark.hadoop.fs.s3a.aws.credentials.provider=org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider" \
--conf "spark.hadoop.fs.s3a.path.style.access=true" \
--conf "spark.executor.extraClassPath=/opt/spark/jars/aws-java-sdk-bundle-1.11.375.jar:/opt/spark/jars/hadoop-aws-3.2.0.jar" \
--conf "spark.driver.extraClassPath=/opt/spark/jars/aws-java-sdk-bundle-1.11.375.jar:/opt/spark/jars/hadoop-aws-3.2.0.jar" \
--class com.amberdata.task.Test \
s3a://dolphxxxxxxxxxxxxxxxx/test.jar
the shell command runs successful,but spark plugin failed[shell脚本运行成功，但是spark插件运行失败]，
the failed reason is that you need to specify spark.kubernetes.file.upload.path for the jars,but the jars will be upload to one of the Dolphinscheduler‘s worker node,not to a pod ,that is too stupid,I suppose it will upload to the executor pod,when the task run over,this pod should be destoryed,and the same as the jar,but it does not,why?
### What you expected to happen
I do not know
### How to reproduce
no
### Anything else
no
### Version
3.2.x
### Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@dolphinscheduler.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Submitting tasks to a K8s environment using Spark plugins yields different results compared to using shell and Spark plugins,even thougth the same command [dolphinscheduler]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #16505:
URL: https://github.com/apache/dolphinscheduler/issues/16505#issuecomment-2304319299
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and found no similar issues.
### What happened
shell command as same spark like：
$SPARK_HOME/bin/spark-submit \
--name cluster-model-app \
--verbose \
--master k8s://https://192.168.10.40:6443 \
--deploy-mode cluster \
--conf spark.network.timeout=300 \
--conf spark.executor.instances=2 \
--conf spark.kubernetes.namespace=dev \
--conf spark.kubernetes.container.image.pullPolicy=IfNotPresent \
--conf spark.kubernetes.container.image=hzent/spark:hadoop3.2 \
--conf spark.kubernetes.container.image.pullSecrets=dev-image-secret \
--conf spark.kubernetes.authenticate.driver.serviceAccountName=scheduler \
--conf spark.kubernetes.authenticate.executor.serviceAccountName=scheduler \
--conf "spark.hadoop.fs.s3a.access.key=xxxX" \
--conf spark.kubernetes.executor.deleteOnTermination=true \
--conf "spark.hadoop.fs.s3a.secret.key=xxxx" \
--conf "spark.hadoop.fs.s3a.endpoint=http://minio.xxxx:9000" \
--conf "spark.hadoop.fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem" \
--conf "spark.hadoop.fs.s3a.aws.credentials.provider=org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider" \
--conf "spark.hadoop.fs.s3a.path.style.access=true" \
--conf "spark.executor.extraClassPath=/opt/spark/jars/aws-java-sdk-bundle-1.11.375.jar:/opt/spark/jars/hadoop-aws-3.2.0.jar" \
--conf "spark.driver.extraClassPath=/opt/spark/jars/aws-java-sdk-bundle-1.11.375.jar:/opt/spark/jars/hadoop-aws-3.2.0.jar" \
--class com.amberdata.task.Test \
s3a://dolphxxxxxxxxxxxxxxxx/test.jar
the shell command runs successful,but spark plugin failed[shell脚本运行成功，但是spark插件运行失败]，
the failed reason is that you need to specify spark.kubernetes.file.upload.path for the jars,but the jars will be upload to one of the Dolphinscheduler‘s worker node,not to a pod ,that is too stupid,I suppose it will upload to the executor pod,when the task run over,this pod should be destoryed,and the same as the jar,but it does not,why?
### What you expected to happen
I do not know
### How to reproduce
no
### Anything else
no
### Version
3.2.x
### Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@dolphinscheduler.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Submitting tasks to a K8s environment using Spark plugins yields different results compared to using shell and Spark plugins,even thougth the same command [dolphinscheduler]
Posted by "SbloodyS (via GitHub)" <gi...@apache.org>.
SbloodyS closed issue #16505: Submitting tasks to a K8s environment using Spark plugins yields different results compared to using shell and Spark plugins,even thougth the same command
URL: https://github.com/apache/dolphinscheduler/issues/16505
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@dolphinscheduler.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Submitting tasks to a K8s environment using Spark plugins yields different results compared to using shell and Spark plugins,even thougth the same command [dolphinscheduler]
Posted by "SbloodyS (via GitHub)" <gi...@apache.org>.
SbloodyS commented on issue #16505:
URL: https://github.com/apache/dolphinscheduler/issues/16505#issuecomment-2305996834
Spark on k8s not supported right now. Would you like to improve it? @qwe3144
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@dolphinscheduler.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org