-
Notifications
You must be signed in to change notification settings - Fork 28.9k
[SPARK-7608] Clean up old state in RDDOperationGraphListener #6125
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
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.
You forget to insert jobId to jobIds. Could you write a simple test to verify we won't leak anything.
|
You have to add unit tests that check for cleanup. For all components that keep track of information. |
|
Test build #32638 has finished for PR 6125 at commit
|
|
LGTM |
|
retest this please |
1 similar comment
|
retest this please |
|
Test build #32633 timed out for PR 6125 at commit |
|
Test build #32643 has finished for PR 6125 at commit
|
|
Master 1.4 |
This is necessary for streaming and long-running Spark applications. zsxwing tdas Author: Andrew Or <[email protected]> Closes #6125 from andrewor14/viz-listener-leak and squashes the following commits: 8660949 [Andrew Or] Fix thing + add tests 33c0843 [Andrew Or] Clean up old job state (cherry picked from commit f6e1838) Signed-off-by: Andrew Or <[email protected]>
zsxwing Author: Andrew Or <[email protected]> Closes #6138 from andrewor14/dag-viz-clean-properly and squashes the following commits: 19d4e98 [Andrew Or] Add synchronize 02542d6 [Andrew Or] Rename overloaded variable d11bee1 [Andrew Or] Don't wait until all stages have started before rendering
zsxwing Author: Andrew Or <[email protected]> Closes #6138 from andrewor14/dag-viz-clean-properly and squashes the following commits: 19d4e98 [Andrew Or] Add synchronize 02542d6 [Andrew Or] Rename overloaded variable d11bee1 [Andrew Or] Don't wait until all stages have started before rendering
This is necessary for streaming and long-running Spark applications. zsxwing tdas Author: Andrew Or <[email protected]> Closes apache#6125 from andrewor14/viz-listener-leak and squashes the following commits: 8660949 [Andrew Or] Fix thing + add tests 33c0843 [Andrew Or] Clean up old job state
zsxwing Author: Andrew Or <[email protected]> Closes apache#6138 from andrewor14/dag-viz-clean-properly and squashes the following commits: 19d4e98 [Andrew Or] Add synchronize 02542d6 [Andrew Or] Rename overloaded variable d11bee1 [Andrew Or] Don't wait until all stages have started before rendering
This is necessary for streaming and long-running Spark applications. zsxwing tdas Author: Andrew Or <[email protected]> Closes apache#6125 from andrewor14/viz-listener-leak and squashes the following commits: 8660949 [Andrew Or] Fix thing + add tests 33c0843 [Andrew Or] Clean up old job state
zsxwing Author: Andrew Or <[email protected]> Closes apache#6138 from andrewor14/dag-viz-clean-properly and squashes the following commits: 19d4e98 [Andrew Or] Add synchronize 02542d6 [Andrew Or] Rename overloaded variable d11bee1 [Andrew Or] Don't wait until all stages have started before rendering
This is necessary for streaming and long-running Spark applications. zsxwing tdas Author: Andrew Or <[email protected]> Closes apache#6125 from andrewor14/viz-listener-leak and squashes the following commits: 8660949 [Andrew Or] Fix thing + add tests 33c0843 [Andrew Or] Clean up old job state
zsxwing Author: Andrew Or <[email protected]> Closes apache#6138 from andrewor14/dag-viz-clean-properly and squashes the following commits: 19d4e98 [Andrew Or] Add synchronize 02542d6 [Andrew Or] Rename overloaded variable d11bee1 [Andrew Or] Don't wait until all stages have started before rendering
This is necessary for streaming and long-running Spark applications. @zsxwing @tdas