-
Notifications
You must be signed in to change notification settings - Fork 149
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[MINOR] feat(spark-client): Support set accessId by another config dynamically #2250
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #2250 +/- ##
============================================
+ Coverage 52.65% 52.88% +0.23%
- Complexity 3376 3552 +176
============================================
Files 514 532 +18
Lines 27565 29315 +1750
Branches 2582 2724 +142
============================================
+ Hits 14513 15502 +989
- Misses 12092 12824 +732
- Partials 960 989 +29 ☔ View full report in Codecov by Sentry. |
@@ -322,6 +322,9 @@ public class RssSparkConfig { | |||
|
|||
public static final ConfigEntry<String> RSS_ACCESS_ID = | |||
createStringBuilder(new ConfigBuilder("spark.rss.access.id")).createWithDefault(""); | |||
public static final ConfigEntry<String> RSS_ACCESS_ID_PROVIDER_KEY = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Could you use camel style?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done.
I renamed to spark.rss.access.id.providerKey
.
Could you add document, too? |
@jerqi Thanks for remind me, document added, PTAL. |
@jerqi Thanks for your review, merge it. |
…namically (apache#2250) ### What changes were proposed in this pull request? Support set accessId by another config dynamically. ### Why are the changes needed? Without this PR, we have to set accessId for each user belongs to `spark.yarn.queue`, after patch this feature, the `spark.access.id` set to the value of `spark.yarn.queue`, if we set `spark.rss.access.id.provider.key=spark.yarn.queue` ### Does this PR introduce _any_ user-facing change? Introduce spark new config `spark.rss.access.id.provider.key`. ### How was this patch tested? Updated UT. (cherry picked from commit b00b67c)
What changes were proposed in this pull request?
Support set accessId by another config dynamically.
Why are the changes needed?
Without this PR, we have to set accessId for each user belongs to
spark.yarn.queue
, after patch this feature, thespark.access.id
set to the value ofspark.yarn.queue
, if we setspark.rss.access.id.provider.key=spark.yarn.queue
Does this PR introduce any user-facing change?
Introduce spark new config
spark.rss.access.id.provider.key
.How was this patch tested?
Updated UT.