[ignite-3] 01/01: IGNITE-16562 .

[sd...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sdanilov pushed a commit to branch ignite-16562
in repository https://gitbox.apache.org/repos/asf/ignite-3.git

commit 8ec0ac45613007b93dc0317fd27386bfbb8459f3
Author: Semyon Danilov <sa...@yandex.ru>
AuthorDate: Mon Feb 21 16:23:47 2022 +0300

    IGNITE-16562 .
---
 .../internal/sql/engine/ItSortAggregateTest.java   | 33 +++++++++++++++++-----
 1 file changed, 26 insertions(+), 7 deletions(-)

diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSortAggregateTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSortAggregateTest.java
index 4ac7024..e3e5429 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSortAggregateTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSortAggregateTest.java
@@ -19,6 +19,9 @@ package org.apache.ignite.internal.sql.engine;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
+import java.lang.management.ManagementFactory;
+import java.lang.management.ThreadInfo;
+import java.lang.management.ThreadMXBean;
 import java.util.List;
 import org.apache.ignite.internal.schema.configuration.SchemaConfigurationConverter;
 import org.apache.ignite.schema.SchemaBuilders;
@@ -28,13 +31,12 @@ import org.apache.ignite.table.RecordView;
 import org.apache.ignite.table.Table;
 import org.apache.ignite.table.Tuple;
 import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 /**
  * Sort aggregate integration test.
  */
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+//@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
 public class ItSortAggregateTest extends AbstractBasicIntegrationTest {
     public static final int ROWS = 103;
 
@@ -75,7 +77,7 @@ public class ItSortAggregateTest extends AbstractBasicIntegrationTest {
 
         Table table = CLUSTER_NODES.get(0).tables().createTable(schTbl1.canonicalName(), tblCh ->
                 SchemaConfigurationConverter.convert(schTbl1, tblCh)
-                        .changeReplicas(2)
+                        .changeReplicas(1)
                         .changePartitions(10)
         );
 
@@ -85,15 +87,20 @@ public class ItSortAggregateTest extends AbstractBasicIntegrationTest {
 
         RecordView<Tuple> view = table.recordView();
         for (int i = 0; i < ROWS; i++) {
-            view.insert(
-                    null,
-                    Tuple.create()
+            try {
+                view.insert(
+                        null,
+                        Tuple.create()
                             .set("ID", i)
                             .set("GRP0", i / 10)
                             .set("GRP1", i / 100)
                             .set("VAL0", 1)
                             .set("VAL1", 2)
-            );
+                );
+            } catch (Exception e) {
+                dumpThreads();
+                throw e;
+            }
         }
 
         RecordView<Tuple> view1 = tblOneColIdx.recordView();
@@ -132,4 +139,16 @@ public class ItSortAggregateTest extends AbstractBasicIntegrationTest {
 
         assertEquals(ROWS, cursors.size());
     }
+
+    /**
+     * Dump JVM threads.
+     */
+    public static void dumpThreads() {
+        ThreadMXBean bean = ManagementFactory.getThreadMXBean();
+        ThreadInfo[] infos = bean.dumpAllThreads(true, true);
+
+        for (ThreadInfo info : infos) {
+            System.out.println(info);
+        }
+    }
 }