Skip to content
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.

Sign up for GitHub

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

Jump to bottom

[FEATURE] Fail long waiting statement #80

Closed
Tracked by #2089
penghuo opened this issue Oct 19, 2023 · 2 comments
Closed
Tracked by #2089

[FEATURE] Fail long waiting statement #80

penghuo opened this issue Oct 19, 2023 · 2 comments
Labels
0.1.1 enhancement New feature or request untriaged

Comments

@penghuo
Copy link
Collaborator

penghuo commented Oct 19, 2023

when spark job pick up the statement, if the statement in waiting state longer than 10 minutes compare to submitTime, spark job should put the state to FAIL and error = timeout.
@penghuo penghuo added enhancement New feature or request untriaged and removed untriaged labels Oct 19, 2023
@penghuo penghuo mentioned this issue Oct 19, 2023
Open
46 tasks
@kaituo
Copy link
Collaborator

kaituo commented Oct 20, 2023

I am using spark.sparkContext.cancelJobGroup(flintCommand.queryId) to cancel query.

@penghuo penghuo added the 0.1.1 label Oct 23, 2023
@kaituo kaituo mentioned this issue Oct 24, 2023
Merged
@kaituo
Copy link
Collaborator

kaituo commented Nov 8, 2023

already implemented in above PR.

@kaituo kaituo closed this as completed Nov 8, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
0.1.1 enhancement New feature or request untriaged
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@penghuo @kaituo