Skip to content

Commit

Permalink
[FLINK-29859][e2e] Add allowed exceptions in logs for speculative exe…
Browse files Browse the repository at this point in the history
…cution e2e

Add 2 more allowed exceptions in logs for speculative execution:
1. java.nio.channels.ClosedChannelException
2. java.lang.IllegalStateException: File writer is already closed

This closes apache#21820.
  • Loading branch information
wanglijie95 authored and zhuzhurk committed Feb 2, 2023
1 parent 615fde6 commit 19f2230
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion flink-end-to-end-tests/test-scripts/test_tpcds.sh
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,9 @@ function check_logs_for_exceptions_for_adaptive_batch_scheduler {
local additional_allowed_exceptions=("ExecutionGraphException: The execution attempt" \
"Cannot find task to fail for execution" \
"ExceptionInChainedOperatorException: Could not forward element to next operator" \
"CancelTaskException: Buffer pool has already been destroyed")
"CancelTaskException: Buffer pool has already been destroyed" \
"java.nio.channels.ClosedChannelException" \
"java.lang.IllegalStateException: File writer is already closed")

internal_check_logs_for_exceptions "${additional_allowed_exceptions[@]}"
}
Expand Down

0 comments on commit 19f2230

Please sign in to comment.