commit 144951be9b2f329f3fdd28a8d266ffcf17274c43
author Anton Vinogradov <av@apache.org> Thu Aug 16 19:20:42 2018 +0300
committer Anton Vinogradov <av@apache.org> Thu Aug 16 19:20:42 2018 +0300
tree 012d64189d6456d24c84f77001e3741438dfad9f
parent da3b7a0ab52b2cb451a8cb2adbabbef7c0d46086

IGNITE-9053 testReentrantLockConstantTopologyChangeNonFailoverSafe can hang in case of broken tx

Signed-off-by: Anton Vinogradov <av@apache.org>

modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
index 84ff2a5..f71246c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
@@ -1192,11 +1192,11 @@
                         }
 
                         LT.warn(log, "Failed to wait for ack message. [node=" + nodeId +
-                            "routine=" + routineId + "]");
+                            ", routine=" + routineId + "]");
                     }
                 }
 
-                assert fut.isDone();
+                assert fut.isDone() : "Future in not finished [fut= " + fut + "]";
             }
             else {
                 final GridContinuousBatch batch = info.add(obj);