[ 
https://issues.apache.org/jira/browse/IGNITE-26308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Igor Sapego updated IGNITE-26308:
---------------------------------
    Labels: MakeTeamcityGreenAgain ignite-3  (was: ignite-3)

> Python test test_fetch_table.test_fetch_table_several_pages(8000) is flaky
> --------------------------------------------------------------------------
>
>                 Key: IGNITE-26308
>                 URL: https://issues.apache.org/jira/browse/IGNITE-26308
>             Project: Ignite
>          Issue Type: Bug
>          Components: platforms ai3, thin clients ai3
>            Reporter: Igor Sapego
>            Assignee: Igor Sapego
>            Priority: Major
>              Labels: MakeTeamcityGreenAgain, ignite-3
>             Fix For: 3.1
>
>
> https://ci.ignite.apache.org/buildConfiguration/ApacheIgnite3xGradle_Test_RunAllTests/9413644
> Looks like the connection is closed by timeout:
> Heartbeats could solve the issue
> {noformat}
> tests.test_fetch_table.test_fetch_table_several_pages(8000)
>     [2025-08-20T18:16:53,335][INFO ] 
> [m[%org.apache.ignite.internal.runner.app.PlatformTestNodeRunner%sql-execution-pool-0]
>  [m[ClientInboundMessageHandler] [m Partition primary replica changed, 
> notifying client [connectionId=335, remoteAddress=/127.0.0.1:38100]
>     ...
>     [2025-08-20T18:17:00,012][INFO ] 
> [m[%org.apache.ignite.internal.runner.app.PlatformTestNodeRunner%metrics-exporter-logPush-0]
>  [m[LogPushExporter] [m Metric report:
>     metastorage [IdempotentCacheSize=96, SafeTimeLag=302]
>     placement-driver [ActiveLeasesCount=0, CurrentPendingAssignmentsSize=0, 
> CurrentStableAssignmentsSize=35, LeasesCreated=0, LeasesProlonged=0, 
> LeasesPublished=0, LeasesWithoutCandidates=0]
>     resource.vacuum [MarkedForVacuumTransactionMetaCount=105, 
> SkippedForFurtherProcessingUnfinishedTransactionCount=0, 
> VacuumizedPersistentTransactionMetaCount=0, VacuumizedVolatileTxnMetaCount=27]
>     tests/test_fetch_table.py:167 (test_fetch_table_several_pages[8000])
>     table_name = 'test_fetch_table_several_pages'
>     cursor = <pyignite_dbapi.Cursor object at 0x7fe0c9154130>
>     drop_table_cleanup = None, rows_num = 8000
>     
>         @pytest.mark.parametrize("rows_num", [
>             TEST_PAGE_SIZE - 1,
>             TEST_PAGE_SIZE,
>             TEST_PAGE_SIZE + 1,
>             TEST_PAGE_SIZE * 2,
>             TEST_PAGE_SIZE * 2 + 1,
>             8000,
>         ])
>         def test_fetch_table_several_pages(table_name, cursor, 
> drop_table_cleanup, rows_num):
>     >       create_and_populate_test_table(cursor, rows_num, table_name, 1000)
>     
>     tests/test_fetch_table.py:177: 
>     _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
> _ _ _ 
>     tests/util.py:170: in create_and_populate_test_table
>         cursor.executemany(f"insert into {table_name} values(?, ?, ?)",
>     _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
> _ _ _ 
>     
>     self = <pyignite_dbapi.Cursor object at 0x7fe0c9154130>
>     query = 'insert into test_fetch_table_several_pages values(?, ?, ?)'
>     params_list = [(1000, 'Value-2000', 500.0), (1001, 'Value-2002', 500.5), 
> (1002, 'Value-2004', 501.0), (1003, 'Value-2006', 501.5), (1004, 
> 'Value-2008', 502.0), (1005, 'Value-2010', 502.5), ...]
>     
>         def executemany(self, query: str, params_list: List[Sequence[Any]]):
>             if self._py_cursor is None:
>                 raise InterfaceError('Cursor is already closed')
>         
>     >       self._py_cursor.executemany(query, params_list)
>     E       pyignite_dbapi.OperationalError: Can not receive a message from 
> the server due to connection error
>     
>     pyignite_dbapi/__init__.py:451: OperationalError
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to