You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/06/11 15:06:10 UTC
[flink] 02/10: [hotfix][runtime] Set root cause to pending request
released exception
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
commit 9c2e15aab6a69084305100fd353cc295ff858206
Author: Zhu Zhu <re...@gmail.com>
AuthorDate: Wed May 20 01:01:33 2020 +0800
[hotfix][runtime] Set root cause to pending request released exception
---
.../org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java
index 44ba3ff..cd0024a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java
@@ -473,7 +473,9 @@ public class SlotPoolImpl implements SlotPool {
final PendingRequest pendingRequest = removePendingRequest(slotRequestId);
if (pendingRequest != null) {
- failPendingRequest(pendingRequest, new FlinkException("Pending slot request with " + slotRequestId + " has been released."));
+ failPendingRequest(
+ pendingRequest,
+ new FlinkException("Pending slot request with " + slotRequestId + " has been released.", cause));
} else {
final AllocatedSlot allocatedSlot = allocatedSlots.remove(slotRequestId);