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);