You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sd...@apache.org on 2022/03/05 12:47:18 UTC
[ignite-3] 01/02: IGNITE-15655 enable all tests
This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a commit to branch ignite-15655-new-network
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit b006a55b1f83468d0181431467d3beea28db1999
Author: Mirza Aliev <al...@gmail.com>
AuthorDate: Wed Feb 9 11:53:16 2022 +0300
IGNITE-15655 enable all tests
---
.../app/jdbc/ItJdbcComplexQuerySelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcConnectionSelfTest.java | 2 +-
.../app/jdbc/ItJdbcDeleteStatementSelfTest.java | 2 +-
.../app/jdbc/ItJdbcErrorsAbstractSelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcErrorsSelfTest.java | 2 +-
.../app/jdbc/ItJdbcInsertStatementSelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcJoinsSelfTest.java | 2 +-
.../jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcMetadataSelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcResultSetSelfTest.java | 2 +-
.../app/jdbc/ItJdbcSelectAfterAlterTable.java | 2 +-
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 2 +-
.../app/jdbc/ItJdbcUpdateStatementSelfTest.java | 111 ++++-----------------
.../internal/sql/engine/ItAggregatesTest.java | 2 +-
.../internal/sql/engine/ItFunctionsTest.java | 2 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 4 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 2 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 2 +-
.../sql/engine/ItProjectScanMergeRuleTest.java | 2 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 8 +-
.../internal/sql/engine/ItSortAggregateTest.java | 4 +-
21 files changed, 45 insertions(+), 116 deletions(-)
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcComplexQuerySelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcComplexQuerySelfTest.java
index a36b6b8..547398a 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcComplexQuerySelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcComplexQuerySelfTest.java
@@ -36,7 +36,7 @@ import org.junit.jupiter.api.Test;
/**
* Tests for complex queries (joins, etc.).
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcComplexQuerySelfTest extends AbstractJdbcSelfTest {
@BeforeAll
public static void createTable() throws Exception {
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcConnectionSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcConnectionSelfTest.java
index 99e7c7c..e05d1e2 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcConnectionSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcConnectionSelfTest.java
@@ -62,7 +62,7 @@ import org.junit.jupiter.api.Test;
* Connection test.
*/
@SuppressWarnings("ThrowableNotThrown")
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcConnectionSelfTest extends AbstractJdbcSelfTest {
/**
* Test JDBC loading via ServiceLoader.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcDeleteStatementSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcDeleteStatementSelfTest.java
index 786ab71..98e03fe 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcDeleteStatementSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcDeleteStatementSelfTest.java
@@ -30,7 +30,7 @@ import org.junit.jupiter.api.Test;
/**
* Delete functional statement self test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcDeleteStatementSelfTest extends ItJdbcAbstractStatementSelfTest {
/**
* Execute delete query test.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsAbstractSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsAbstractSelfTest.java
index 55aff1e..a645421 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsAbstractSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsAbstractSelfTest.java
@@ -45,7 +45,7 @@ import org.junit.jupiter.api.Test;
/**
* Test SQLSTATE codes propagation with (any) Ignite JDBC driver.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public abstract class ItJdbcErrorsAbstractSelfTest extends AbstractJdbcSelfTest {
/**
* Test that parsing-related error codes get propagated to Ignite SQL exceptions.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsSelfTest.java
index 09017ab..cf781a4 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcErrorsSelfTest.java
@@ -35,7 +35,7 @@ import org.junit.jupiter.api.Test;
/**
* Test SQLSTATE codes propagation with thin client driver.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcErrorsSelfTest extends ItJdbcErrorsAbstractSelfTest {
/** {@inheritDoc} */
@Override protected Connection getConnection() throws SQLException {
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcInsertStatementSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcInsertStatementSelfTest.java
index 0dc6098..b55d3c9 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcInsertStatementSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcInsertStatementSelfTest.java
@@ -35,7 +35,7 @@ import org.junit.jupiter.api.Test;
/**
* Statement test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcInsertStatementSelfTest extends ItJdbcAbstractStatementSelfTest {
/** SQL SELECT query for verification. */
private static final String SQL_SELECT = "select sid, id, firstName, lastName, age from PUBLIC.PERSON";
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcJoinsSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcJoinsSelfTest.java
index 7416362..016eacf 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcJoinsSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcJoinsSelfTest.java
@@ -29,7 +29,7 @@ import org.junit.jupiter.api.Test;
/**
* Tests for complex queries with joins.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcJoinsSelfTest extends AbstractJdbcSelfTest {
/**
* Check distributed OUTER join of 3 tables (T1 -> T2 -> T3) returns correct result for non-collocated data.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java
index 6ee86c7..3f6cf6f 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java
@@ -33,7 +33,7 @@ import org.junit.jupiter.api.Test;
/**
* Verifies that primary keys in the metadata are valid.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcMetadataPrimaryKeysSelfTest extends AbstractJdbcSelfTest {
/** COLUMN_NAME column index in the metadata table. */
private static final int COL_NAME_IDX = 4;
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataSelfTest.java
index f0dd23e..b259765 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcMetadataSelfTest.java
@@ -57,7 +57,7 @@ import org.junit.jupiter.api.Test;
/**
* Metadata tests.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcMetadataSelfTest extends AbstractJdbcSelfTest {
/** Creates tables. */
@BeforeAll
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcResultSetSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcResultSetSelfTest.java
index f07859a..7e634aa 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcResultSetSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcResultSetSelfTest.java
@@ -58,7 +58,7 @@ import org.junit.jupiter.api.Test;
/**
* Result set test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcResultSetSelfTest extends AbstractJdbcSelfTest {
/** SQL static query. */
private static final String STATIC_SQL =
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcSelectAfterAlterTable.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcSelectAfterAlterTable.java
index 135439d..e92f397 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcSelectAfterAlterTable.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcSelectAfterAlterTable.java
@@ -32,7 +32,7 @@ import org.junit.jupiter.api.Test;
/**
* Base class for complex SQL tests based on JDBC driver.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcSelectAfterAlterTable extends AbstractJdbcSelfTest {
/** {@inheritDoc} */
@BeforeEach
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementSelfTest.java
index 4897306..68c5c1b 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementSelfTest.java
@@ -42,7 +42,7 @@ import org.junit.jupiter.api.Test;
/**
* Statement test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJdbcStatementSelfTest extends ItJdbcAbstractStatementSelfTest {
/** SQL query. */
private static final String SQL = "select * from PERSON where age > 30";
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcUpdateStatementSelfTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcUpdateStatementSelfTest.java
index dbe6909..1a5b08e 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcUpdateStatementSelfTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcUpdateStatementSelfTest.java
@@ -18,123 +18,52 @@
package org.apache.ignite.internal.runner.app.jdbc;
import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-import static org.junit.jupiter.api.Assertions.fail;
-import java.sql.ResultSet;
import java.sql.SQLException;
-import java.util.function.Consumer;
import org.apache.ignite.table.KeyValueView;
+import org.apache.ignite.table.Tuple;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
/**
* Update statement self test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
-public class ItJdbcUpdateStatementSelfTest extends AbstractJdbcSelfTest {
+
+public class ItJdbcUpdateStatementSelfTest extends ItJdbcAbstractStatementSelfTest {
/**
* Execute test.
*
* @throws SQLException If failed.
*/
@Test
- public void testExecuteUpdateMultipleColumnsUpdate() throws Exception {
- final String q1 = "CREATE TABLE usertable (\n"
- + " ycsb_key1 int NOT NULL,\n"
- + " ycsb_key2 varchar(3) NOT NULL,\n"
- + " field1 varchar(100),\n"
- + " field2 varchar(100),\n"
- + " field3 varchar(100),\n"
- + " field4 varchar(100),\n"
- + " field5 varchar(100),\n"
- + " field6 varchar(100),\n"
- + " field7 varchar(100),\n"
- + " field8 varchar(100),\n"
- + " field9 varchar(100),\n"
- + " field10 varchar(100),\n"
- + " PRIMARY KEY(ycsb_key1, ycsb_key2)\n"
- + ");";
-
- final String q2 = "INSERT INTO usertable values(1, 'key', 'a1','a2','a3','a4','a5','a6','a7','a8','a9','a10');";
-
- final String q3 = "UPDATE usertable SET FIELD1='b1',FIELD2='b2',FIELD3='b3',FIELD4='b4',FIELD5='b5',"
- + "FIELD6='b6',FIELD7='b7',FIELD8='b8',FIELD9='b9',FIELD10='b10' WHERE YCSB_KEY1=1";
-
- final String q4 = "DROP TABLE usertable;";
-
- assertEquals(0, stmt.executeUpdate(q1));
- assertEquals(1, stmt.executeUpdate(q2));
- assertEquals(1, stmt.executeUpdate(q3));
+ public void testExecute() throws SQLException {
+ stmt.execute("update PUBLIC.PERSON set firstName = 'Jack' where substring(SID, 2, 1)::int % 2 = 0");
- stmt.executeQuery("SELECT * FROM usertable WHERE YCSB_KEY1=1;");
+ KeyValueView<Tuple, Tuple> person = clusterNodes.get(0).tables()
+ .table("PUBLIC.PERSON").keyValueView();
- ResultSet resultSet = stmt.getResultSet();
-
- assertTrue(resultSet.next());
-
- for (int i = 1; i < 11; i++) {
- assertEquals("b" + i, resultSet.getString(i + 2));
- }
-
- assertEquals(0, stmt.executeUpdate(q4));
+ assertEquals("John", person.get(null, Tuple.create().set("ID", 1)).stringValue("FIRSTNAME"));
+ assertEquals("Jack", person.get(null, Tuple.create().set("ID", 2)).stringValue("FIRSTNAME"));
+ assertEquals("Mike", person.get(null, Tuple.create().set("ID", 3)).stringValue("FIRSTNAME"));
}
/**
- * Execute test.
+ * Execute update test.
*
* @throws SQLException If failed.
*/
@Test
- public void testExecuteAndExecuteUpdate() throws SQLException {
- testExecute((String updateQuery) -> {
- try {
- stmt.executeUpdate(updateQuery);
- } catch (SQLException e) {
- fail(e);
- }
- });
+ public void testExecuteUpdate() throws SQLException {
+ int i = stmt.executeUpdate(
+ "update PUBLIC.PERSON set firstName = 'Jack' where substring(SID, 2, 1)::int % 2 = 0");
- testExecute((String updateQuery) -> {
- try {
- stmt.execute(updateQuery);
- } catch (SQLException e) {
- fail(e);
- }
- });
- }
-
- private void testExecute(Consumer<String> updateFunction) throws SQLException {
- final String createSql = "CREATE TABLE public.person(id INTEGER PRIMARY KEY, sid VARCHAR,"
- + " firstname VARCHAR NOT NULL, lastname VARCHAR NOT NULL, age INTEGER NOT NULL)";
-
- final String insertSql = "INSERT INTO public.person(sid, id, firstname, lastname, age) VALUES "
- + "('p1', 1, 'John', 'White', 25), "
- + "('p2', 2, 'Joe', 'Black', 35), "
- + "('p3', 3, 'Mike', 'Green', 40)";
-
- final String updateSql = "update PUBLIC.PERSON set firstName = 'Jack' where substring(SID, 2, 1)::int % 2 = 0";
-
- final String dropSql = "DROP TABLE PUBLIC.PERSON;";
+ assertEquals(1, i);
- updateFunction.accept(createSql);
- updateFunction.accept(insertSql);
- updateFunction.accept(updateSql);
-
- KeyValueView<Integer, Person> person = clusterNodes.get(0).tables()
- .table("PUBLIC.PERSON").keyValueView(Integer.class, Person.class);
-
- assertEquals("John", person.get(null, 1).firstname);
- assertEquals("Jack", person.get(null, 2).firstname);
- assertEquals("Mike", person.get(null, 3).firstname);
-
- updateFunction.accept(dropSql);
- }
+ KeyValueView<Tuple, Tuple> person = clusterNodes.get(0).tables()
+ .table("PUBLIC.PERSON").keyValueView();
- private static class Person {
- public int age;
- public String sid;
- public String firstname;
- public String lastname;
+ assertEquals("John", person.get(null, Tuple.create().set("ID", 1)).stringValue("FIRSTNAME"));
+ assertEquals("Jack", person.get(null, Tuple.create().set("ID", 2)).stringValue("FIRSTNAME"));
+ assertEquals("Mike", person.get(null, Tuple.create().set("ID", 3)).stringValue("FIRSTNAME"));
}
}
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItAggregatesTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItAggregatesTest.java
index ea370e2..773e529 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItAggregatesTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItAggregatesTest.java
@@ -30,7 +30,7 @@ import org.junit.jupiter.api.Test;
/**
* Group of tests to verify aggregation functions.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItAggregatesTest extends AbstractBasicIntegrationTest {
/**
* Before all.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItFunctionsTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItFunctionsTest.java
index 67540b6..1ebfb99 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItFunctionsTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItFunctionsTest.java
@@ -42,7 +42,7 @@ import org.junit.jupiter.api.Test;
/**
* Test Ignite SQL functions.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItFunctionsTest extends AbstractBasicIntegrationTest {
private static final Object[] NULL_RESULT = new Object[] { null };
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItIndexSpoolTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItIndexSpoolTest.java
index 3714c29..f0fcbf9 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItIndexSpoolTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItIndexSpoolTest.java
@@ -38,7 +38,7 @@ import org.junit.jupiter.params.provider.ValueSource;
/**
* Index spool test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItIndexSpoolTest extends AbstractBasicIntegrationTest {
private static final IgniteLogger LOG = IgniteLogger.forClass(AbstractBasicIntegrationTest.class);
@@ -99,7 +99,7 @@ public class ItIndexSpoolTest extends AbstractBasicIntegrationTest {
return CLUSTER_NODES.get(0).tables().createTable(schTbl1.canonicalName(), tblCh ->
SchemaConfigurationConverter.convert(schTbl1, tblCh)
- .changeReplicas(2)
+ .changeReplicas(1)
.changePartitions(10)
);
}
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItJoinTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItJoinTest.java
index e612c9b..d237880 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItJoinTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItJoinTest.java
@@ -31,7 +31,7 @@ import org.junit.jupiter.params.provider.EnumSource;
/**
* Check JOIN on basic cases.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItJoinTest extends AbstractBasicIntegrationTest {
@BeforeAll
public static void beforeTestsStarted() {
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMetadataTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMetadataTest.java
index ea0dd72..9baf22a 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMetadataTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMetadataTest.java
@@ -31,7 +31,7 @@ import org.junit.jupiter.api.Test;
/**
* Group of tests to verify the query metadata returned alongside the query result.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItMetadataTest extends AbstractBasicIntegrationTest {
/**
* Before all.
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItProjectScanMergeRuleTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItProjectScanMergeRuleTest.java
index f7d244a..f841e50 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItProjectScanMergeRuleTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItProjectScanMergeRuleTest.java
@@ -38,7 +38,7 @@ import org.junit.jupiter.api.Test;
* with only useful columns and. For example for tables: T1(f12, f12, f13) and T2(f21, f22, f23) sql execution: SELECT t1.f11, t2.f21 FROM
* T1 t1 INNER JOIN T2 t2 on t1.f11 = t2.f22" need to eleminate all unused coluns and take into account only: f11, f21 and f22 cols.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItProjectScanMergeRuleTest extends AbstractBasicIntegrationTest {
public static final String IDX_CAT_ID = "IDX_CAT_ID";
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSetOpTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSetOpTest.java
index 3ab9a49..dd88e15 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSetOpTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSetOpTest.java
@@ -36,7 +36,7 @@ import org.junit.jupiter.api.Test;
/**
* Integration test for set op (EXCEPT, INTERSECT).
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItSetOpTest extends AbstractBasicIntegrationTest {
/**
* Before all.
@@ -124,7 +124,7 @@ public class ItSetOpTest extends AbstractBasicIntegrationTest {
Table tbl1 = CLUSTER_NODES.get(0).tables().createTable(schTbl1.canonicalName(), tblCh ->
SchemaConfigurationConverter.convert(schTbl1, tblCh)
- .changeReplicas(2)
+ .changeReplicas(1)
.changePartitions(10)
);
@@ -138,7 +138,7 @@ public class ItSetOpTest extends AbstractBasicIntegrationTest {
Table tbl2 = CLUSTER_NODES.get(0).tables().createTable(schTbl2.canonicalName(), tblCh ->
SchemaConfigurationConverter.convert(schTbl2, tblCh)
- .changeReplicas(2)
+ .changeReplicas(1)
.changePartitions(10)
);
@@ -276,7 +276,7 @@ public class ItSetOpTest extends AbstractBasicIntegrationTest {
return CLUSTER_NODES.get(0).tables().createTable(schTbl1.canonicalName(), tblCh ->
SchemaConfigurationConverter.convert(schTbl1, tblCh)
- .changeReplicas(2)
+ .changeReplicas(1)
.changePartitions(10)
);
}
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..d6bdf62 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
@@ -34,7 +34,7 @@ import org.junit.jupiter.api.Test;
/**
* Sort aggregate integration test.
*/
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-15655")
+
public class ItSortAggregateTest extends AbstractBasicIntegrationTest {
public static final int ROWS = 103;
@@ -75,7 +75,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)
);