This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 19f2230a475 [FLINK-29859][e2e] Add allowed exceptions in logs for
speculative execution e2e
19f2230a475 is described below
commit 19f2230a4758f471305727ad82d36984ebbc7e3a
Author: Lijie Wang <wangdachui9...@gmail.com>
AuthorDate: Wed Feb 1 17:05:32 2023 +0800
[FLINK-29859][e2e] Add allowed exceptions in logs for speculative execution
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 #21820.
---
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-end-to-end-tests/test-scripts/test_tpcds.sh
b/flink-end-to-end-tests/test-scripts/test_tpcds.sh
index 585f0c2c866..4065c927ac3 100755
--- a/flink-end-to-end-tests/test-scripts/test_tpcds.sh
+++ b/flink-end-to-end-tests/test-scripts/test_tpcds.sh
@@ -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[@]}"
}
