You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by gv...@apache.org on 2019/01/29 12:10:55 UTC
[ignite] branch master updated: IGNITE-10764: MVCC: Transactions
failed to acquire lock within timeout. This closes #5910.
This is an automated email from the ASF dual-hosted git repository.
gvvinblade pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new c30a467 IGNITE-10764: MVCC: Transactions failed to acquire lock within timeout. This closes #5910.
c30a467 is described below
commit c30a46785f0b4e918525b6e5e9b42095af62a779
Author: ipavlukhin <vo...@gmail.com>
AuthorDate: Tue Jan 29 15:10:39 2019 +0300
IGNITE-10764: MVCC: Transactions failed to acquire lock within timeout. This closes #5910.
Signed-off-by: rkondakov <ko...@mail.ru>
---
.../processors/cache/mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccSqlTxQueriesAbstractTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccSqlTxQueriesAbstractTest.java
index 7f0dcf0..61eb608 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccSqlTxQueriesAbstractTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccSqlTxQueriesAbstractTest.java
@@ -1132,7 +1132,7 @@ public abstract class CacheMvccSqlTxQueriesAbstractTest extends CacheMvccAbstrac
Ignite checkNode = grid(rnd.nextInt(4));
Ignite updateNode = grid(rnd.nextInt(4));
- IgniteCache cache = checkNode.cache(DEFAULT_CACHE_NAME);
+ IgniteCache<Object, Object> cache = checkNode.cache(DEFAULT_CACHE_NAME);
cache.putAll(F.asMap(
1, new MvccTestSqlIndexValue(1),
@@ -1157,9 +1157,9 @@ public abstract class CacheMvccSqlTxQueriesAbstractTest extends CacheMvccAbstrac
/**
* @throws Exception If failed.
*/
- @Ignore("https://issues.apache.org/jira/browse/IGNITE-10764")
@Test
public void testQueryInsertMultithread() throws Exception {
+ // Reopen https://issues.apache.org/jira/browse/IGNITE-10764 if test starts failing with timeout
final int THREAD_CNT = 8;
final int BATCH_SIZE = 1000;
final int ROUNDS = 10;
@@ -1199,11 +1199,10 @@ public abstract class CacheMvccSqlTxQueriesAbstractTest extends CacheMvccAbstrac
Ignite checkNode = grid(rnd.nextInt(4));
Ignite updateNode = grid(rnd.nextInt(4));
- IgniteCache cache = checkNode.cache(DEFAULT_CACHE_NAME);
+ IgniteCache<Object, Object> cache = checkNode.cache(DEFAULT_CACHE_NAME);
+ // no tx timeout here, deadlocks should not happen because all keys are unique
try (Transaction tx = updateNode.transactions().txStart(PESSIMISTIC, REPEATABLE_READ)) {
- tx.timeout(TX_TIMEOUT);
-
SqlFieldsQuery qry = new SqlFieldsQuery(bldr.toString()).setPageSize(100);
IgniteCache<Object, Object> cache0 = updateNode.cache(DEFAULT_CACHE_NAME);