(ignite-3) branch main updated: IGNITE-26033 Sql. Fix TestClusterTest.testHybridTimestampPropagationToInitiator (#6392)

[korlov]

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 <kor...@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());