[
https://issues.apache.org/jira/browse/IGNITE-26687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18033391#comment-18033391
]
Igor Sapego commented on IGNITE-26687:
--------------------------------------
Seems like the same error:
https://ci.ignite.apache.org/buildConfiguration/ApacheIgnite3xGradle_Test_RunPythonClientTests/9576899?showLog=9576899_2118_518.2118&logFilter=debug&logView=flowAware
> Flaky tests.test_executemany.test_executemany_success
> -----------------------------------------------------
>
> Key: IGNITE-26687
> URL: https://issues.apache.org/jira/browse/IGNITE-26687
> Project: Ignite
> Issue Type: Improvement
> Components: platforms ai3
> Reporter: Iurii Gerzhedovich
> Assignee: Igor Sapego
> Priority: Major
> Labels: MakeTeamcityGreenAgain, ignite-3
>
> The test
> [tests.test_executemany.test_executemany_success(300)|https://ci.ignite.apache.org/buildConfiguration/ApacheIgnite3xGradle_Test_RunAllTests/9541027]
> is flaky
> {code:java}
> tests/test_executemany.py:17 (test_executemany_success[300])
> 18:17:32 table_name = 'test_executemany_success'
> cursor = <pyignite_dbapi.Cursor object at 0x7f45968c9670>
> drop_table_cleanup = None, batch_size = 300
>
> @pytest.mark.parametrize("batch_size", [1, 2, 10, 300])
> def test_executemany_success(table_name, cursor, drop_table_cleanup,
> batch_size):
> test_data = [(i, f'data_{i}') for i in range(batch_size)]
>
> cursor.execute(f'create table {table_name}(id int primary key,
> data varchar)')
> > cursor.executemany(f"insert into {table_name} values(?, ?)",
> test_data)
>
> tests/test_executemany.py:23:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _
>
> self = <pyignite_dbapi.Cursor object at 0x7f45968c9670>
> query = 'insert into test_executemany_success values(?, ?)'
> params_list = [(0, 'data_0'), (1, 'data_1'), (2, 'data_2'), (3,
> 'data_3'), (4, 'data_4'), (5, 'data_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 {code}
> potential root cause is
> {code:java}
> [2025-10-10T15:17:25,681][ERROR][%org.apache.ignite.internal.runner.app.PlatformTestNodeRunner_2%metastorage-watch-executor-0][JmxExporter]
> MBean for metric set can't be created
> [name=storage.aipersist.tables.PUBLIC.TEST_EXECUTEMANY_SUCCESS].
> [m
> javax.management.InstanceAlreadyExistsException:
> org.apache.ignite:nodeName=org.apache.ignite.internal.runner.app.PlatformTestNodeRunner_2,type=metrics,group=storage,name="aipersist.tables.PUBLIC.TEST_EXECUTEMANY_SUCCESS"
> at
> java.management/com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:436)
> at
> java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1865)
> at
> java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:960)
> at
> java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:895)
> at
> java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:320)
> at
> java.management/com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:523)
> at
> org.apache.ignite.internal.metrics.exporters.jmx.JmxExporter.register(JmxExporter.java:123)
> at
> org.apache.ignite.internal.metrics.exporters.jmx.JmxExporter.addMetricSet(JmxExporter.java:100)
> at
> org.apache.ignite.internal.metrics.MetricManagerImpl.lambda$enable$6(MetricManagerImpl.java:203)
> at
> java.base/java.util.concurrent.ConcurrentHashMap$ValuesView.forEach(ConcurrentHashMap.java:4780)
> at
> org.apache.ignite.internal.metrics.MetricManagerImpl.lambda$enable$7(MetricManagerImpl.java:203)
> at
> org.apache.ignite.internal.util.IgniteUtils.inBusyLock(IgniteUtils.java:883)
> at
> org.apache.ignite.internal.metrics.MetricManagerImpl.enable(MetricManagerImpl.java:199)
> at
> org.apache.ignite.internal.table.distributed.TableManager.createAndRegisterMetricsSource(TableManager.java:3652)
> at
> org.apache.ignite.internal.table.distributed.TableManager.createTableImpl(TableManager.java:1844)
> at
> org.apache.ignite.internal.table.distributed.TableManager.loadTableToZoneOnTableCreate(TableManager.java:909)
> at
> org.apache.ignite.internal.table.distributed.TableManager.loadTableToZoneOnTableCreate(TableManager.java:899)
> at
> org.apache.ignite.internal.event.AbstractEventProducer.fireEvent(AbstractEventProducer.java:88)
> at
> org.apache.ignite.internal.catalog.CatalogManagerImpl.access$000(CatalogManagerImpl.java:81)
> at
> org.apache.ignite.internal.catalog.CatalogManagerImpl$OnUpdateHandlerImpl.handle(CatalogManagerImpl.java:519)
> at
> org.apache.ignite.internal.catalog.CatalogManagerImpl$OnUpdateHandlerImpl.handle(CatalogManagerImpl.java:486)
> at
> org.apache.ignite.internal.catalog.storage.UpdateLogImpl$UpdateListener.onUpdate(UpdateLogImpl.java:348)
> at
> org.apache.ignite.internal.metastorage.server.Watch.onUpdate(Watch.java:67)
> at
> org.apache.ignite.internal.metastorage.server.WatchProcessor.performWatchesNotifications(WatchProcessor.java:317)
> at
> org.apache.ignite.internal.metastorage.server.WatchProcessor.lambda$notifyWatchesInternal$7(WatchProcessor.java:264)
> at
> org.apache.ignite.internal.util.IgniteUtils.inBusyLockAsync(IgniteUtils.java:941)
> at
> org.apache.ignite.internal.metastorage.server.WatchProcessor.inBusyLockAsync(WatchProcessor.java:193)
> at
> org.apache.ignite.internal.metastorage.server.WatchProcessor.lambda$enqueue$2(WatchProcessor.java:239)
> at
> java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150)
> at
> java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
> at java.base/java.lang.Thread.run(Thread.java:833) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
