You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/15 09:14:37 UTC
[flink] branch master updated: [FLINK-12290][runtime] Clarify
exception message
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 5eeeb82 [FLINK-12290][runtime] Clarify exception message
5eeeb82 is described below
commit 5eeeb8291ad2c1fe9e4dceab3cd921e7aba619e5
Author: liyafan82 <42...@users.noreply.github.com>
AuthorDate: Wed May 15 17:14:26 2019 +0800
[FLINK-12290][runtime] Clarify exception message
---
.../src/main/java/org/apache/flink/runtime/instance/SharedSlot.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java
index 4998d26..0f9c104 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java
@@ -195,7 +195,7 @@ public class SharedSlot extends Slot implements LogicalSlot {
assignmentGroup.releaseSharedSlot(this);
if (!(isReleased() && subSlots.isEmpty())) {
- throw new IllegalStateException("Bug: SharedSlot is not empty and released after call to releaseSlot()");
+ throw new IllegalStateException("Bug: SharedSlot is not released or not empty after call to releaseSlot()");
}
return CompletableFuture.completedFuture(null);