Skip to content

Comments

[SPARK-30371][K8S] Add spark.kubernetes.driver.master conf#27029

Closed
wackxu wants to merge 1 commit intoapache:masterfrom
wackxu:internalmaster
Closed

[SPARK-30371][K8S] Add spark.kubernetes.driver.master conf#27029
wackxu wants to merge 1 commit intoapache:masterfrom
wackxu:internalmaster

Conversation

@wackxu
Copy link
Contributor

@wackxu wackxu commented Dec 28, 2019

What changes were proposed in this pull request?

make KUBERNETES_MASTER_INTERNAL_URL configurable

Why are the changes needed?

we do not always use the default port number 443 to access our kube-apiserver, and even in some mulit-tenant cluster, people do not use the service kubernetes.default.svc to access the kube-apiserver, so make the internal master configurable is necessary。

Does this PR introduce any user-facing change?

user can configure the internal master url by

--conf spark.kubernetes.driver.master=https://kubernetes.default.svc:6443

How was this patch tested?

run in multi-cluster that do not use the https://kubernetes.default.svc to access the kube-apiserver

@wackxu
Copy link
Contributor Author

wackxu commented Dec 30, 2019

/assign @liyinan926

@wackxu
Copy link
Contributor Author

wackxu commented Jan 9, 2020

@liyinan926 Could you take a look at this?

@wackxu
Copy link
Contributor Author

wackxu commented Jan 11, 2020

@dongjoon-hyun Could you take a look at this?

@dongjoon-hyun dongjoon-hyun changed the title [SPARK-30371][K8S]make KUBERNETES_MASTER_INTERNAL_URL configurable [SPARK-30371][K8S] Make KUBERNETES_MASTER_INTERNAL_URL configurable Jan 11, 2020
@dongjoon-hyun
Copy link
Member

Thank you for pinging me, @wackxu.

@dongjoon-hyun
Copy link
Member

ok to test

@SparkQA
Copy link

SparkQA commented Jan 11, 2020

Test build #116537 has finished for PR 27029 at commit 05820de.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

Copy link
Member

@dongjoon-hyun dongjoon-hyun left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

One additional request is the following.

You had better make this PR complete by itself and you can do.

@SparkQA
Copy link

SparkQA commented Jan 11, 2020

Kubernetes integration test starting
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21323/

@SparkQA
Copy link

SparkQA commented Jan 11, 2020

Kubernetes integration test status failure
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21323/

@wackxu wackxu force-pushed the internalmaster branch 2 times, most recently from 9091a3d to 1cc2de5 Compare January 16, 2020 08:58
@SparkQA
Copy link

SparkQA commented Jan 16, 2020

Test build #116838 has finished for PR 27029 at commit 1cc2de5.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@SparkQA
Copy link

SparkQA commented Jan 16, 2020

Kubernetes integration test starting
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21610/

@SparkQA
Copy link

SparkQA commented Jan 16, 2020

Kubernetes integration test status failure
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21610/

@dongjoon-hyun
Copy link
Member

Hi, @wackxu Could you address @liyinan926 's comments?

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Test build #117000 has finished for PR 27029 at commit 3c0d369.

  • This patch fails Scala style tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Kubernetes integration test starting
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21767/

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Kubernetes integration test status failure
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21767/

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Test build #117003 has finished for PR 27029 at commit a8cb113.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@wackxu
Copy link
Contributor Author

wackxu commented Jan 19, 2020

Hi, @wackxu Could you address @liyinan926 's comments?

@liyinan926 @dongjoon-hyun Sorry for the deplay, updated.

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Kubernetes integration test starting
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21770/

@SparkQA
Copy link

SparkQA commented Jan 19, 2020

Kubernetes integration test status failure
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/21770/

@dongjoon-hyun
Copy link
Member

The only failure in K8S integration tests is the following, but it's known to be flaky in these days.

- Launcher client dependencies *** FAILED ***

Copy link
Member

@dongjoon-hyun dongjoon-hyun left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1, LGTM. Thank you, @wackxu and @liyinan926 .
Merged to master.

@dongjoon-hyun dongjoon-hyun changed the title [SPARK-30371][K8S] Make KUBERNETES_MASTER_INTERNAL_URL configurable [SPARK-30371][K8S] Add spark.kubernetes.driver.master conf Jan 19, 2020
@dongjoon-hyun
Copy link
Member

@wackxu . You are added to the Apache Spark contributor group. Congratulation!

@wackxu
Copy link
Contributor Author

wackxu commented Jan 20, 2020

@dongjoon-hyun @liyinan926 Thank you for your patient response and detailed review.

@wackxu wackxu deleted the internalmaster branch January 20, 2020 06:17
ayuan37 pushed a commit to ayuan37/spark that referenced this pull request Feb 22, 2021
### What changes were proposed in this pull request?

make KUBERNETES_MASTER_INTERNAL_URL configurable

### Why are the changes needed?

we do not always use the default port number 443 to access our kube-apiserver, and even in some mulit-tenant cluster,  people do not use the service `kubernetes.default.svc` to access the kube-apiserver, so make the internal master configurable is necessary。

### Does this PR introduce any user-facing change?

user can configure the internal master url by
```
--conf spark.kubernetes.internal.master=https://kubernetes.default.svc:6443
```

### How was this patch tested?

run in multi-cluster that do not use the https://kubernetes.default.svc to access the kube-apiserver

Closes apache#27029 from wackxu/internalmaster.

Authored-by: xushiwei 00425595 <xushiwei5@huawei.com>
Signed-off-by: Dongjoon Hyun <dhyun@apple.com>
rshkv pushed a commit to palantir/spark that referenced this pull request Feb 22, 2021
### What changes were proposed in this pull request?

make KUBERNETES_MASTER_INTERNAL_URL configurable

### Why are the changes needed?

we do not always use the default port number 443 to access our kube-apiserver, and even in some mulit-tenant cluster,  people do not use the service `kubernetes.default.svc` to access the kube-apiserver, so make the internal master configurable is necessary。

### Does this PR introduce any user-facing change?

user can configure the internal master url by
```
--conf spark.kubernetes.internal.master=https://kubernetes.default.svc:6443
```

### How was this patch tested?

run in multi-cluster that do not use the https://kubernetes.default.svc to access the kube-apiserver

Closes apache#27029 from wackxu/internalmaster.

Authored-by: xushiwei 00425595 <xushiwei5@huawei.com>
Signed-off-by: Dongjoon Hyun <dhyun@apple.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants