[
https://issues.apache.org/jira/browse/IGNITE-27451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18047662#comment-18047662
]
Ignite TC Bot commented on IGNITE-27451:
----------------------------------------
{panel:title=Branch: [pull/12610/head] Base: [master] : Possible Blockers
(1)|borderStyle=dashed|borderColor=#ccc|titleBGColor=#F7D6C1}
{color:#d04437}Queries 1{color} [[tests
1|https://ci2.ignite.apache.org/viewLog.html?buildId=8775704]]
* IgniteBinaryCacheQueryTestSuite:
DynamicIndexServerCoordinatorBasicSelfTest.testCreateIndexWithParallelismPartitionedAtomicNear
- Test has low fail rate in base branch 0,0% and is not flaky
{panel}
{panel:title=Branch: [pull/12610/head] Base: [master] : New Tests
(1)|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1}
{color:#00008b}Service Grid{color} [[tests
1|https://ci2.ignite.apache.org/viewLog.html?buildId=8775714]]
* {color:#013220}IgniteServiceGridTestSuite: ServiceConcurrentUndeployTest.test
- PASSED{color}
{panel}
[TeamCity *--> Run :: All*
Results|https://ci2.ignite.apache.org/viewLog.html?buildId=8775745&buildTypeId=IgniteTests24Java8_RunAll]
> Service#cancel java.lang.AssertionError: Concurrent map modification
> --------------------------------------------------------------------
>
> Key: IGNITE-27451
> URL: https://issues.apache.org/jira/browse/IGNITE-27451
> Project: Ignite
> Issue Type: Bug
> Reporter: Nikolay Izhikov
> Assignee: Nikolay Izhikov
> Priority: Major
> Time Spent: 1h 10m
> Remaining Estimate: 0h
>
> {code:java}
> package org.apache.ignite.internal.processors.service;
> import java.util.concurrent.CountDownLatch;
> import java.util.concurrent.ExecutorService;
> import java.util.concurrent.Executors;
> import java.util.concurrent.ThreadLocalRandom;
> import org.apache.ignite.configuration.IgniteConfiguration;
> import org.apache.ignite.internal.IgniteEx;
> import
> org.apache.ignite.internal.processors.service.inner.LongInitializedTestService;
> import org.apache.ignite.lang.IgniteFuture;
> import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
> import org.junit.Test;
> /**
> * Tests concurrent deploy/undeploy services. */
> public class ServiceConcurrentDeployUndeployTest extends
> GridCommonAbstractTest {
> /** */
> private static final int THREAD_CNT = 10;
> /** */
> private static final int EXECUTION_CNT = 100;
> /** */
> private final ExecutorService executor =
> Executors.newFixedThreadPool(THREAD_CNT);
> /** */
> @Test
> public void test() throws Exception {
> CountDownLatch latch = new CountDownLatch(EXECUTION_CNT * THREAD_CNT);
> try (IgniteEx ignite = startGrids(4)) {
> for (int t = 0; t < THREAD_CNT; t++) {
> for (int i = 0; i < EXECUTION_CNT; i++) {
> String threadName = String.format("worker-%s-%s", t, i);
> executor.submit(getServiceRunnable(threadName, latch));
> }
> }
> latch.await();
> }
> }
> /** */
> private Runnable getServiceRunnable(String srvcName, CountDownLatch
> latch) {
> return () -> {
> try {
> IgniteConfiguration cfg = getConfiguration("client-" +
> srvcName);
> try (IgniteEx client = startClientGrid(cfg)) {
> long delay = ThreadLocalRandom.current().nextLong(1001);
> IgniteFuture<Void> fut =
> client.services().deployNodeSingletonAsync(srvcName, new
> LongInitializedTestService(delay));
> fut.get();
> client.services().cancelAll();
> latch.countDown();
> }
> }
> catch (Exception e) {
> log.error("Unexpected error [" + srvcName + "]", e);
> }
> };
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
