Skip to content

Conversation

@gaborgsomogyi
Copy link
Contributor

@gaborgsomogyi gaborgsomogyi commented Dec 7, 2018

What changes were proposed in this pull request?

spark.kafka.sasl.kerberos.service.name is an optional parameter but most of the time value kafka has to be set. As I've written in the jira the following reasoning is behind:

In this PR I've changed the parameter from optional to WithDefault and set kafka as default value.

How was this patch tested?

Available unit tests + on cluster.

@SparkQA
Copy link

SparkQA commented Dec 7, 2018

Test build #99826 has finished for PR 23254 at commit 3f56e78.

  • This patch fails Spark unit tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@gaborgsomogyi
Copy link
Contributor Author

retest this please

@gaborgsomogyi
Copy link
Contributor Author

Unrelated, filed jira: https://issues.apache.org/jira/browse/SPARK-26306

@SparkQA
Copy link

SparkQA commented Dec 7, 2018

Test build #99830 has finished for PR 23254 at commit 3f56e78.

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

@gaborgsomogyi
Copy link
Contributor Author

gaborgsomogyi commented Dec 7, 2018

cc @vanzin @HeartSaVioR

@vanzin
Copy link
Contributor

vanzin commented Dec 7, 2018

Merging to master.

@asfgit asfgit closed this in 9b1f6c8 Dec 7, 2018
jackylee-ch pushed a commit to jackylee-ch/spark that referenced this pull request Feb 18, 2019
…ice.name parameter

## What changes were proposed in this pull request?

spark.kafka.sasl.kerberos.service.name is an optional parameter but most of the time value `kafka` has to be set. As I've written in the jira the following reasoning is behind:
* Kafka's configuration guide suggest the same value: https://kafka.apache.org/documentation/#security_sasl_kerberos_brokerconfig
* It would be easier for spark users by providing less configuration
* Other streaming engines are doing the same

In this PR I've changed the parameter from optional to `WithDefault` and set `kafka` as default value.

## How was this patch tested?

Available unit tests + on cluster.

Closes apache#23254 from gaborgsomogyi/SPARK-26304.

Authored-by: Gabor Somogyi <[email protected]>
Signed-off-by: Marcelo Vanzin <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants