You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ko...@apache.org on 2025/08/12 06:09:10 UTC
(ignite-3) branch main updated: IGNITE-26033 Sql. Fix TestClusterTest.testHybridTimestampPropagationToInitiator (#6392)
This is an automated email from the ASF dual-hosted git repository.
korlov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new b2bf5f6ffa4 IGNITE-26033 Sql. Fix TestClusterTest.testHybridTimestampPropagationToInitiator (#6392)
b2bf5f6ffa4 is described below
commit b2bf5f6ffa448fb48faec46d22764ab947dec802
Author: korlov42 <ko...@apache.org>
AuthorDate: Tue Aug 12 09:09:04 2025 +0300
IGNITE-26033 Sql. Fix TestClusterTest.testHybridTimestampPropagationToInitiator (#6392)
---
.../sql/engine/framework/TestClusterTest.java | 19 ++++++++++---------
1 file changed, 10 insertions(+), 9 deletions(-)
diff --git a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/framework/TestClusterTest.java b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/framework/TestClusterTest.java
index bc8504644fe..d1a2aa48489 100644
--- a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/framework/TestClusterTest.java
+++ b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/framework/TestClusterTest.java
@@ -38,6 +38,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Flow.Publisher;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
+import org.apache.ignite.internal.catalog.commands.CatalogUtils;
import org.apache.ignite.internal.hlc.HybridClock;
import org.apache.ignite.internal.sql.engine.InternalSqlRow;
import org.apache.ignite.internal.sql.engine.exec.AsyncDataCursor;
@@ -71,6 +72,7 @@ import org.junit.jupiter.api.Test;
* Tests for test execution runtime used in benchmarking.
*/
public class TestClusterTest extends BaseIgniteAbstractTest {
+ private static final int TABLE_SIZE = 10_000;
private final ScannableTable table = new ScannableTable() {
@Override
@@ -80,11 +82,10 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
RowFactory<RowT> rowFactory,
int @Nullable [] requiredColumns
) {
-
return new TransformingPublisher<>(
SubscriptionUtils.fromIterable(
DataProvider.fromRow(
- new Object[]{42, UUID.randomUUID().toString()}, 3_333
+ new Object[]{42, UUID.randomUUID().toString()}, TABLE_SIZE / CatalogUtils.DEFAULT_PARTITION_COUNT
)
), rowFactory::create
);
@@ -189,7 +190,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
assertInstanceOf(MultiStepPlan.class, plan);
assertInstanceOf(IgniteTableScan.class, lastNode(((MultiStepPlan) plan).getRel()));
- for (var row : await(gatewayNode.executeQuery(query).requestNextAsync(10_000)).items()) {
+ for (var row : await(gatewayNode.executeQuery(query).requestNextAsync(TABLE_SIZE)).items()) {
assertNotNull(row);
}
}
@@ -208,7 +209,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
QueryPlan plan = gatewayNode.prepare(query);
- for (var row : await(gatewayNode.executeQuery(query).requestNextAsync(10_000)).items()) {
+ for (var row : await(gatewayNode.executeQuery(query).requestNextAsync(TABLE_SIZE)).items()) {
assertNotNull(row);
}
@@ -226,7 +227,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
QueryPlan plan = gatewayNode.prepare(query);
- for (InternalSqlRow row : await(gatewayNode.executeQuery(query).requestNextAsync(10_000)).items()) {
+ for (InternalSqlRow row : await(gatewayNode.executeQuery(query).requestNextAsync(TABLE_SIZE)).items()) {
assertNotNull(row);
}
@@ -243,7 +244,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
QueryPlan plan = gatewayNode.prepare(query);
- for (InternalSqlRow row : await(gatewayNode.executeQuery(query).requestNextAsync(10_000)).items()) {
+ for (InternalSqlRow row : await(gatewayNode.executeQuery(query).requestNextAsync(TABLE_SIZE)).items()) {
assertNotNull(row);
}
@@ -321,7 +322,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
AsyncCursor<InternalSqlRow> cur = initiator.executeQuery("SELECT * FROM t1");
- await(cur.requestNextAsync(10_000));
+ await(cur.requestNextAsync(TABLE_SIZE));
assertEquals(otherNodeClock.now().getPhysical(), initiatorClock.now().getPhysical());
@@ -344,7 +345,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
BatchedResult<InternalSqlRow> results = await(
gatewayNode.executeQuery("SELECT * FROM SYSTEM.NODES, SYSTEM.NODE_N2")
- .requestNextAsync(10_000)
+ .requestNextAsync(TABLE_SIZE)
);
List<List<Object>> rows = convertSqlRows(results.items());
@@ -371,7 +372,7 @@ public class TestClusterTest extends BaseIgniteAbstractTest {
BatchedResult<InternalSqlRow> results = await(
gatewayNode.executeQuery("SELECT 'hello', COUNT(*) FROM t1")
- .requestNextAsync(10_000)
+ .requestNextAsync(TABLE_SIZE)
);
List<List<Object>> rows = convertSqlRows(results.items());