Skip to content

Add EarlyTerminationException to prevent logging too many invalid error messages#5174

Merged
Jackie-Jiang merged 2 commits intoapache:masterfrom
Jackie-Jiang:operator_interrupt
Mar 24, 2020
Merged

Add EarlyTerminationException to prevent logging too many invalid error messages#5174
Jackie-Jiang merged 2 commits intoapache:masterfrom
Jackie-Jiang:operator_interrupt

Conversation

@Jackie-Jiang
Copy link
Copy Markdown
Contributor

When a query times out or is already satisfied, we will cancal the operator execution for early termination.
In such case, we should not log error messages as the interruptions are intentional.
In case of timeout, it will still be logged in the combine operators once, but not for each individual operators.

…or messages

When a query times out or is already satisfied, we will cancal the operator execution for early termination.
In such case, we should not log error messages as the interruptions are intentional.
In case of timeout, it will still be logged in the combine operators once, but not for each individual operators.
Copy link
Copy Markdown
Member

@jackjlli jackjlli left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In case of timeout, it will still be logged in the combine operators once, but not for each individual operators.
Can you point out the message logged in combine operators? I don't see it in this PR though.

}
}
blockingQueue.offer(mergedBlock);
} catch (EarlyTerminationException e) {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you add some unit tests/ integration tests for this?

@Jackie-Jiang
Copy link
Copy Markdown
Contributor Author

@jackjlli It is very hard to test the logger behavior. I added some comments in CombineSlowOperatorsTest for the expected behavior.

@Jackie-Jiang Jackie-Jiang merged commit b8ed426 into apache:master Mar 24, 2020
@Jackie-Jiang Jackie-Jiang deleted the operator_interrupt branch March 24, 2020 02:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants