svn commit: r58727 - in /release/ignite/ignite-extensions/ignite-spark-ext: 2.0.0./ 2.0.0/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:54:39 2022
New Revision: 58727

Log:
Release ignite-spark-ext-2.0.0: Binaries

Added:
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/
  - copied from r58726, 
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0./
Removed:
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0./

svn commit: r58726 - /release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:54:17 2022
New Revision: 58726

Log: (empty)

Removed:
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/

svn commit: r58725 - in /release/ignite/ignite-extensions/ignite-spark-ext: 2.0.0./ 2.0.0/ignite-spark-ext-2.0.0-rc1/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:52:58 2022
New Revision: 58725

Log:
Release ignite-spark-ext-2.0.0: Binaries

Added:
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0./
  - copied from r58724, 
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/ignite-spark-ext-2.0.0-rc1/
Removed:

release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/ignite-spark-ext-2.0.0-rc1/

svn commit: r58724 - /dev/ignite/ignite-extensions/ignite-spark-ext-3.0.0-rc1/ /release/ignite/ignite-extensions/ignite-spark-ext/3.0.0/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:51:59 2022
New Revision: 58724

Log:
Release ignite-spark-ext-3.0.0: Binaries

Added:
release/ignite/ignite-extensions/ignite-spark-ext/3.0.0/
  - copied from r58723, 
dev/ignite/ignite-extensions/ignite-spark-ext-3.0.0-rc1/
Removed:
dev/ignite/ignite-extensions/ignite-spark-ext-3.0.0-rc1/

svn commit: r58723 - /dev/ignite/ignite-extensions/ignite-spark-ext-2.0.0-rc1/ /release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/ignite-spark-ext-2.0.0-rc1/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:37:12 2022
New Revision: 58723

Log:
Release ignite-spark-ext-2.0.0: Binaries

Added:

release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/ignite-spark-ext-2.0.0-rc1/
  - copied from r58722, 
dev/ignite/ignite-extensions/ignite-spark-ext-2.0.0-rc1/
Removed:
dev/ignite/ignite-extensions/ignite-spark-ext-2.0.0-rc1/

svn commit: r58722 - in /release/ignite/ignite-extensions/ignite-spark-ext: ./ 2.0.0/

2022-12-14 Thread mmuzaf 
Author: mmuzaf
Date: Wed Dec 14 21:37:05 2022
New Revision: 58722

Log: (empty)

Added:
release/ignite/ignite-extensions/ignite-spark-ext/
release/ignite/ignite-extensions/ignite-spark-ext/2.0.0/

[ignite-3] branch main updated: IGNITE-18071 Add client-side heartbeat timeout (#1448)

2022-12-14 Thread ptupitsyn 
This is an automated email from the ASF dual-hosted git repository.

ptupitsyn 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 c7ea5c8bd5 IGNITE-18071 Add client-side heartbeat timeout (#1448)
c7ea5c8bd5 is described below

commit c7ea5c8bd5811316e5facb54cd8d72f501681137
Author: Pavel Tupitsyn 
AuthorDate: Wed Dec 14 21:36:00 2022 +0300

IGNITE-18071 Add client-side heartbeat timeout (#1448)

* Add `IgniteClientConfiguration.heartbeatTimeout`.
* Close connection when there is no response from server to heartbeat 
message within the specified timeout.
* Minor fixes - add nullable annotations, improve logger handling.
* Add test for `connectTimeout`.
* Fix Netty buffer leak in case of connect timeout.
---
 .idea/inspectionProfiles/Project_Default.xml   |  2 +-
 .../org/apache/ignite/client/IgniteClient.java | 27 --
 .../ignite/client/IgniteClientConfiguration.java   | 18 +++--
 .../apache/ignite/internal/client/ClientUtils.java | 20 ++
 .../client/IgniteClientConfigurationImpl.java  | 16 +++-
 .../ignite/internal/client/ReliableChannel.java|  4 +-
 .../ignite/internal/client/TcpClientChannel.java   | 43 +++---
 .../ignite/internal/client/TcpIgniteClient.java| 10 +
 .../apache/ignite/client/AbstractClientTest.java   |  2 +-
 .../apache/ignite/client/ClientComputeTest.java|  6 +--
 .../org/apache/ignite/client/ConnectionTest.java   | 23 +++-
 .../org/apache/ignite/client/HeartbeatTest.java| 28 ++
 .../org/apache/ignite/client/MultiClusterTest.java |  6 +--
 .../org/apache/ignite/client/RetryPolicyTest.java  |  4 +-
 .../ignite/client/TestClientHandlerModule.java | 35 ++
 .../java/org/apache/ignite/client/TestServer.java  | 15 ++--
 16 files changed, 220 insertions(+), 39 deletions(-)

diff --git a/.idea/inspectionProfiles/Project_Default.xml 
b/.idea/inspectionProfiles/Project_Default.xml
index a77fb48328..2b5ac76e01 100644
--- a/.idea/inspectionProfiles/Project_Default.xml
+++ b/.idea/inspectionProfiles/Project_Default.xml
@@ -1185,4 +1185,4 @@
   
 
   
-
\ No newline at end of file
+
diff --git 
a/modules/client/src/main/java/org/apache/ignite/client/IgniteClient.java 
b/modules/client/src/main/java/org/apache/ignite/client/IgniteClient.java
index 9f5b5c123d..5580f2f331 100644
--- a/modules/client/src/main/java/org/apache/ignite/client/IgniteClient.java
+++ b/modules/client/src/main/java/org/apache/ignite/client/IgniteClient.java
@@ -19,6 +19,7 @@ package org.apache.ignite.client;
 
 import static 
org.apache.ignite.client.IgniteClientConfiguration.DFLT_CONNECT_TIMEOUT;
 import static 
org.apache.ignite.client.IgniteClientConfiguration.DFLT_HEARTBEAT_INTERVAL;
+import static 
org.apache.ignite.client.IgniteClientConfiguration.DFLT_HEARTBEAT_TIMEOUT;
 import static 
org.apache.ignite.client.IgniteClientConfiguration.DFLT_RECONNECT_THROTTLING_PERIOD;
 import static 
org.apache.ignite.client.IgniteClientConfiguration.DFLT_RECONNECT_THROTTLING_RETRIES;
 import static org.apache.ignite.internal.client.ClientUtils.sync;
@@ -34,6 +35,7 @@ import 
org.apache.ignite.internal.client.IgniteClientConfigurationImpl;
 import org.apache.ignite.internal.client.TcpIgniteClient;
 import org.apache.ignite.lang.LoggerFactory;
 import org.apache.ignite.network.ClusterNode;
+import org.jetbrains.annotations.Nullable;
 
 /**
  * Ignite client entry point.
@@ -86,10 +88,14 @@ public interface IgniteClient extends Ignite {
 /** Heartbeat interval. */
 private long heartbeatInterval = DFLT_HEARTBEAT_INTERVAL;
 
+/** Heartbeat timeout. */
+private long heartbeatTimeout = DFLT_HEARTBEAT_TIMEOUT;
+
 /** Retry policy. */
-private RetryPolicy retryPolicy = new RetryReadPolicy();
+private @Nullable RetryPolicy retryPolicy = new RetryReadPolicy();
 
-private LoggerFactory loggerFactory;
+/** Logger factory. */
+private @Nullable LoggerFactory loggerFactory;
 
 /**
  * Sets the addresses of Ignite server nodes within a cluster. An 
address can be an IP address or a hostname, with or without port.
@@ -116,7 +122,7 @@ public interface IgniteClient extends Ignite {
  * @param retryPolicy Retry policy.
  * @return This instance.
  */
-public Builder retryPolicy(RetryPolicy retryPolicy) {
+public Builder retryPolicy(@Nullable RetryPolicy retryPolicy) {
 this.retryPolicy = retryPolicy;
 
 return this;
@@ -240,6 +246,20 @@ public interface IgniteClient extends Ignite {
 return this;
 }
 
+/**
+ * Sets the heartbeat message timeout, in milliseconds. Default is 
5000.
+ *
+ * When a server does not respond to a heartbeat within the 
specified timeout, client will cl

[ignite-3] branch main updated: IGNITE-18402 ItLogicalTopologyTest.receivesLogicalTopologyEventsCausedByNodeRestart fails locally (#1450)

2022-12-14 Thread ibessonov 
This is an automated email from the ASF dual-hosted git repository.

ibessonov 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 ec3b2a477a IGNITE-18402 
ItLogicalTopologyTest.receivesLogicalTopologyEventsCausedByNodeRestart fails 
locally (#1450)
ec3b2a477a is described below

commit ec3b2a477a9ce2de8549c1f88c49aa6d30eb7390
Author: Roman Puchkovskiy 
AuthorDate: Wed Dec 14 18:42:36 2022 +0400

IGNITE-18402 
ItLogicalTopologyTest.receivesLogicalTopologyEventsCausedByNodeRestart fails 
locally (#1450)
---
 .../ignite/internal/AbstractClusterIntegrationTest.java|  2 --
 .../ignite/internal/compute/ItLogicalTopologyTest.java | 14 ++
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/AbstractClusterIntegrationTest.java
 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/AbstractClusterIntegrationTest.java
index 10fe272c58..7a5dd7035d 100644
--- 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/AbstractClusterIntegrationTest.java
+++ 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/AbstractClusterIntegrationTest.java
@@ -46,7 +46,6 @@ import org.apache.ignite.lang.IgniteStringFormatter;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.TestInfo;
-import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.extension.ExtendWith;
 
 /**
@@ -54,7 +53,6 @@ import org.junit.jupiter.api.extension.ExtendWith;
  */
 @SuppressWarnings("ALL")
 @ExtendWith(WorkDirectoryExtension.class)
-@TestInstance(TestInstance.Lifecycle.PER_CLASS)
 public abstract class AbstractClusterIntegrationTest extends 
BaseIgniteAbstractTest {
 private static final IgniteLogger LOG = 
Loggers.forClass(AbstractClusterIntegrationTest.class);
 
diff --git 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/compute/ItLogicalTopologyTest.java
 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/compute/ItLogicalTopologyTest.java
index e048855e30..8de3186259 100644
--- 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/compute/ItLogicalTopologyTest.java
+++ 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/compute/ItLogicalTopologyTest.java
@@ -34,6 +34,7 @@ import org.apache.ignite.internal.app.IgniteImpl;
 import 
org.apache.ignite.internal.cluster.management.topology.api.LogicalTopologyEventListener;
 import 
org.apache.ignite.internal.cluster.management.topology.api.LogicalTopologySnapshot;
 import org.apache.ignite.internal.network.message.ScaleCubeMessage;
+import org.apache.ignite.internal.tostring.S;
 import org.apache.ignite.network.ClusterNode;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInfo;
@@ -105,17 +106,17 @@ class ItLogicalTopologyTest extends 
AbstractClusterIntegrationTest {
 
 restartNode(1, testInfo);
 
-assertTrue(waitForCondition(() -> events.size() >= 4, 10_000));
+waitForCondition(() -> events.size() >= 2, 10_000);
 
-assertThat(events, hasSize(4));
+assertThat(events, hasSize(2));
 
-Event leaveEvent = events.get(2);
+Event leaveEvent = events.get(0);
 
 assertFalse(leaveEvent.appeared);
 assertThat(leaveEvent.node.name(), is(secondIgnite.name()));
 assertThat(leaveEvent.topologyVersion, is(3L));
 
-Event joinEvent = events.get(3);
+Event joinEvent = events.get(1);
 
 assertTrue(joinEvent.appeared);
 assertThat(joinEvent.node.name(), is(secondIgnite.name()));
@@ -175,5 +176,10 @@ class ItLogicalTopologyTest extends 
AbstractClusterIntegrationTest {
 this.node = node;
 this.topologyVersion = topologyVersion;
 }
+
+@Override
+public String toString() {
+return S.toString(this);
+}
 }
 }

[ignite] branch master updated: Revert "IGNITE-17945 Change message in case watchdog thread observes freeze (#10434)" (#10442)

2022-12-14 Thread timoninmaxim 
This is an automated email from the ASF dual-hosted git repository.

timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
 new f16ce98bace Revert "IGNITE-17945 Change message in case watchdog 
thread observes freeze (#10434)" (#10442)
f16ce98bace is described below

commit f16ce98bace0afa445e0eb2eeb62aee7e35a9079
Author: Maksim Timonin 
AuthorDate: Wed Dec 14 15:38:39 2022 +0300

Revert "IGNITE-17945 Change message in case watchdog thread observes freeze 
(#10434)" (#10442)
---
 .../src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
index 8c1dd047258..1d5ce72a50d 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
@@ -127,8 +127,7 @@ public class LongJVMPauseDetector {
 final long pause = now - PRECISION - lastWakeUpTime;
 
 if (pause >= THRESHOLD) {
-log.warning("Possible too long JVM pause: " + 
pause + " milliseconds. Possible reasons:" +
-" GC pause, hardware temporary freeze, bulk 
loading, other JVM pauses.");
+log.warning("Possible too long JVM pause: " + 
pause + " milliseconds.");
 
 synchronized (LongJVMPauseDetector.this) {
 final int next = (int)(longPausesCnt % 
EVT_CNT);

[ignite] branch revert-10434-IGNITE-17945 created (now b557e2bfdab)

2022-12-14 Thread timoninmaxim 
This is an automated email from the ASF dual-hosted git repository.

timoninmaxim pushed a change to branch revert-10434-IGNITE-17945
in repository https://gitbox.apache.org/repos/asf/ignite.git


  at b557e2bfdab Revert "IGNITE-17945 Change message in case watchdog 
thread observes freeze (#10434)"

This branch includes the following new commits:

 new b557e2bfdab Revert "IGNITE-17945 Change message in case watchdog 
thread observes freeze (#10434)"

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[ignite] 01/01: Revert "IGNITE-17945 Change message in case watchdog thread observes freeze (#10434)"

2022-12-14 Thread timoninmaxim 
This is an automated email from the ASF dual-hosted git repository.

timoninmaxim pushed a commit to branch revert-10434-IGNITE-17945
in repository https://gitbox.apache.org/repos/asf/ignite.git

commit b557e2bfdabacb2b49342d6703dc2b5bae93d4c5
Author: Maksim Timonin 
AuthorDate: Wed Dec 14 15:37:24 2022 +0300

Revert "IGNITE-17945 Change message in case watchdog thread observes freeze 
(#10434)"

This reverts commit 86dc48ea4f93df44d0c11730766cb7002e1e5d84.
---
 .../src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
index 8c1dd047258..1d5ce72a50d 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
@@ -127,8 +127,7 @@ public class LongJVMPauseDetector {
 final long pause = now - PRECISION - lastWakeUpTime;
 
 if (pause >= THRESHOLD) {
-log.warning("Possible too long JVM pause: " + 
pause + " milliseconds. Possible reasons:" +
-" GC pause, hardware temporary freeze, bulk 
loading, other JVM pauses.");
+log.warning("Possible too long JVM pause: " + 
pause + " milliseconds.");
 
 synchronized (LongJVMPauseDetector.this) {
 final int next = (int)(longPausesCnt % 
EVT_CNT);

[ignite] branch master updated: IGNITE-17945 Change message in case watchdog thread observes freeze (#10434)

2022-12-14 Thread timoninmaxim 
This is an automated email from the ASF dual-hosted git repository.

timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
 new 86dc48ea4f9 IGNITE-17945 Change message in case watchdog thread 
observes freeze (#10434)
86dc48ea4f9 is described below

commit 86dc48ea4f93df44d0c11730766cb7002e1e5d84
Author: Julia Bakulina <96814257+j-bak...@users.noreply.github.com>
AuthorDate: Wed Dec 14 13:23:42 2022 +0300

IGNITE-17945 Change message in case watchdog thread observes freeze (#10434)
---
 .../src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
index 1d5ce72a50d..8c1dd047258 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/LongJVMPauseDetector.java
@@ -127,7 +127,8 @@ public class LongJVMPauseDetector {
 final long pause = now - PRECISION - lastWakeUpTime;
 
 if (pause >= THRESHOLD) {
-log.warning("Possible too long JVM pause: " + 
pause + " milliseconds.");
+log.warning("Possible too long JVM pause: " + 
pause + " milliseconds. Possible reasons:" +
+" GC pause, hardware temporary freeze, bulk 
loading, other JVM pauses.");
 
 synchronized (LongJVMPauseDetector.this) {
 final int next = (int)(longPausesCnt % 
EVT_CNT);

[ignite-3] branch main updated: IGNITE-18374 Remove RaftManager#prepareRaftGroup method (#1438)

2022-12-14 Thread ibessonov 
This is an automated email from the ASF dual-hosted git repository.

ibessonov 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 4d2976dd25 IGNITE-18374 Remove RaftManager#prepareRaftGroup method 
(#1438)
4d2976dd25 is described below

commit 4d2976dd25787d2ee047672ee4c94b297244de31
Author: Alexander Polovtcev 
AuthorDate: Wed Dec 14 13:05:23 2022 +0300

IGNITE-18374 Remove RaftManager#prepareRaftGroup method (#1438)
---
 .../management/raft/ItCmgRaftServiceTest.java  | 27 ++---
 .../management/ClusterManagementGroupManager.java  | 20 ---
 .../client/ItMetaStorageServiceTest.java   | 27 ++---
 .../internal/metastorage/MetaStorageManager.java   | 44 --
 .../apache/ignite/internal/raft/RaftManager.java   | 41 +++--
 .../ignite/internal/raft/ItLearnersTest.java   | 10 ++--
 .../apache/ignite/internal/raft/ItLozaTest.java| 13 ++--
 .../internal/raft/ItRaftGroupServiceTest.java  | 14 ++---
 .../java/org/apache/ignite/internal/raft/Loza.java | 70 --
 .../org/apache/ignite/internal/raft/LozaTest.java  |  5 +-
 .../sql/engine/exec/MockedStructuresTest.java  |  2 +-
 .../distributed/ItTxDistributedTestSingleNode.java | 11 ++--
 12 files changed, 120 insertions(+), 164 deletions(-)

diff --git 
a/modules/cluster-management/src/integrationTest/java/org/apache/ignite/internal/cluster/management/raft/ItCmgRaftServiceTest.java
 
b/modules/cluster-management/src/integrationTest/java/org/apache/ignite/internal/cluster/management/raft/ItCmgRaftServiceTest.java
index a17c26388d..8ee84e07b3 100644
--- 
a/modules/cluster-management/src/integrationTest/java/org/apache/ignite/internal/cluster/management/raft/ItCmgRaftServiceTest.java
+++ 
b/modules/cluster-management/src/integrationTest/java/org/apache/ignite/internal/cluster/management/raft/ItCmgRaftServiceTest.java
@@ -21,7 +21,6 @@ import static java.util.stream.Collectors.collectingAndThen;
 import static java.util.stream.Collectors.toSet;
 import static 
org.apache.ignite.internal.cluster.management.ClusterState.clusterState;
 import static 
org.apache.ignite.internal.cluster.management.ClusterTag.clusterTag;
-import static 
org.apache.ignite.internal.cluster.management.CmgGroupId.INSTANCE;
 import static 
org.apache.ignite.internal.testframework.IgniteTestUtils.assertThrowsWithCause;
 import static 
org.apache.ignite.internal.testframework.IgniteTestUtils.waitForCondition;
 import static 
org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.will;
@@ -43,6 +42,7 @@ import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import org.apache.ignite.internal.cluster.management.ClusterState;
 import org.apache.ignite.internal.cluster.management.ClusterTag;
+import org.apache.ignite.internal.cluster.management.CmgGroupId;
 import 
org.apache.ignite.internal.cluster.management.network.messages.CmgMessagesFactory;
 import 
org.apache.ignite.internal.cluster.management.raft.commands.JoinReadyCommand;
 import 
org.apache.ignite.internal.cluster.management.raft.commands.JoinRequestCommand;
@@ -54,8 +54,11 @@ import 
org.apache.ignite.internal.configuration.testframework.InjectConfiguratio
 import org.apache.ignite.internal.hlc.HybridClockImpl;
 import org.apache.ignite.internal.properties.IgniteProductVersion;
 import org.apache.ignite.internal.raft.Loza;
+import org.apache.ignite.internal.raft.Peer;
 import org.apache.ignite.internal.raft.PeersAndLearners;
+import org.apache.ignite.internal.raft.RaftGroupEventsListener;
 import org.apache.ignite.internal.raft.RaftManager;
+import org.apache.ignite.internal.raft.RaftNodeId;
 import org.apache.ignite.internal.raft.configuration.RaftConfiguration;
 import org.apache.ignite.internal.raft.service.RaftGroupService;
 import org.apache.ignite.internal.testframework.WorkDirectory;
@@ -117,12 +120,20 @@ public class ItCmgRaftServiceTest {
 .map(ClusterNode::name)
 .collect(collectingAndThen(toSet(), 
PeersAndLearners::fromConsistentIds));
 
-CompletableFuture raftService = 
raftManager.prepareRaftGroup(
-INSTANCE,
-
configuration.peer(clusterService.topologyService().localMember().name()),
-configuration,
-() -> new CmgRaftGroupListener(raftStorage, new 
LogicalTopologyImpl(raftStorage), term -> {})
-);
+Peer serverPeer = configuration.peer(localMember().name());
+
+CompletableFuture raftService;
+
+if (serverPeer == null) {
+raftService = 
raftManager.startRaftGroupService(CmgGroupId.INSTANCE, configuration);
+} else {
+raftService = raftManager.startRaftGroupNode(
+new RaftNodeId(CmgG

[ignite] branch master updated (9464ca13212 -> ce9b211d349)

2022-12-14 Thread ptupitsyn 
This is an automated email from the ASF dual-hosted git repository.

ptupitsyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


from 9464ca13212 IGNITE-18341 SQL Calcite: Introduce correlated 
distribution - Fixes #10424.
 add ce9b211d349 IGNITE-18262 .NET: Fix missing files and broken examples 
in binary release (#10437)

No new revisions were added by this update.

Summary of changes:
 modules/platforms/dotnet/build.ps1 |  2 +-
 .../platforms/dotnet/examples/.vscode/launch.json  | 82 +++---
 .../dotnet/examples/Directory.Build.props  |  6 +-
 .../Apache.Ignite.Example/ExampleProject.csproj|  2 +-
 .../ExampleProjectThin.csproj  |  2 +-
 .../Apache.Ignite.Examples.csproj  |  2 +-
 6 files changed, 48 insertions(+), 48 deletions(-)