-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-32126][SS] Scope Session.active in IncrementalExecution #28936
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
Conversation
|
Test build #124589 has finished for PR 28936 at commit
|
|
retest this please |
|
Test build #124595 has finished for PR 28936 at commit
|
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, @xuanyuanking . BTW, since Apache Spark 3.0.0 is already released and this patch only is applicable for Apache Spark 3.0.1. So, could you file a new JIRA for this PR? Otherwise, we will lose the traceability for this patch.
cloud-fan
left a comment
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, let's create a new JIRA ticket
|
Thanks, @xuanyuanking and @cloud-fan . I created SPARK-32126 and update the title. |
### What changes were proposed in this pull request? The `optimizedPlan` in IncrementalExecution should also be scoped in `withActive`. ### Why are the changes needed? Follow-up of SPARK-30798 for the Streaming side. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Existing UT. Closes #28936 from xuanyuanking/SPARK-30798-follow. Authored-by: Yuanjian Li <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit f944603) Signed-off-by: Dongjoon Hyun <[email protected]>
|
Sorry for the late. |
What changes were proposed in this pull request?
The
optimizedPlanin IncrementalExecution should also be scoped inwithActive.Why are the changes needed?
Follow-up of SPARK-30798 for the Streaming side.
Does this PR introduce any user-facing change?
No.
How was this patch tested?
Existing UT.