-
Notifications
You must be signed in to change notification settings - Fork 166
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
Fix linked non-cluster-default blob storage not working for HDI cluster issue #4827
Fix linked non-cluster-default blob storage not working for HDI cluster issue #4827
Conversation
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.
Thanks Rui!
@@ -90,7 +90,7 @@ public int hashCode() { | |||
} | |||
|
|||
public String getHadoopBlobFsPropertyKey() { | |||
return String.format("fs.azure.account.key.%s.blob.%s", getStorageAccount(), getEndpointSuffix()); | |||
return String.format("spark.hadoop.fs.azure.account.key.%s.blob.%s", getStorageAccount(), getEndpointSuffix()); |
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.
Let's prefix spark.hadoo.
at the calling side since it's a Spark definition
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.
Good suggestion, will make the change in next iteration
@@ -327,6 +327,14 @@ private Integer parseIntegerSafety(@Nullable Object maybeInteger) { | |||
return messageList; | |||
} | |||
|
|||
@JsonIgnore | |||
public Map<String, Object> updateJobConfig(String key, Object value) { |
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.
I prefer to keep this file minimal changes. We can do it at calling side as below:
submitModel.submissionParameter.getJobConfig().put(SparkSubmissionParameter.Conf, ...)
12582bd
to
2a7529b
Compare
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.
LGTM! Shipit!
No description provided.