-
Notifications
You must be signed in to change notification settings - Fork 14.8k
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 spark operator log retrieval from driver #38106
Fix spark operator log retrieval from driver #38106
Conversation
@eladkal mind taking a look? think this minor change can fix |
8563e18
to
f62045b
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. Can you add the test case for this?
sure |
7e94ea5
to
2a47d16
Compare
@dirrao tests added! |
39bf49d
to
79bb051
Compare
LGTM that makes sense since the older version of k8soperator uses that base container name and not supported multiple container |
fb1783c
to
f294edd
Compare
Signed-off-by: Hai Nguyen <quanghai.ng1512@gmail.com>
Signed-off-by: Hai Nguyen <quanghai.ng1512@gmail.com>
42d4b9e
to
11e0681
Compare
Signed-off-by: Harry <quanghai.ng1512@gmail.com>
11e0681
to
ef0efa3
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 as a bug fix, but it would be nice to support overriding the Spark job container name (in a separate PR).
Related logs:

closes: #37681
Overriding default BASE_CONTAINER_NAME assigns the
container_logs
attribute correctly in further steps, so that in execution airflow can get logs from the correct container.^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named
{pr_number}.significant.rst
or{issue_number}.significant.rst
, in newsfragments.