IGNITE-26965 Fixed flaky ReliabilityTest#testServiceMethodInvocationAfterFailover

Author: petrov-mg

modules/core/src/test/java/org/apache/ignite/client/ReliabilityTest.java

@@ -195,8 +195,7 @@ public void testFailover() throws Exception {
     /**
      * Test single server failover.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testSingleServerFailover() throws Exception {
         try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
              IgniteClient client = Ignition.startClient(getClientConfiguration()
@@ -218,8 +217,7 @@ public void testSingleServerFailover() throws Exception {
     /**
      * Test single server can be used multiple times in configuration.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testSingleServerDuplicatedFailover() throws Exception {
         try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
              IgniteClient client = Ignition.startClient(getClientConfiguration()
@@ -242,8 +240,7 @@ public void testSingleServerDuplicatedFailover() throws Exception {
     /**
      * Test single server can be used multiple times in configuration.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testRetryReadPolicyRetriesCacheGet() {
         try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
              IgniteClient client = Ignition.startClient(getClientConfiguration()
@@ -267,8 +264,7 @@ public void testRetryReadPolicyRetriesCacheGet() {
     /**
      * Tests retry policy exception handling.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testExceptionInRetryPolicyPropagatesToCaller() {
         Assume.assumeFalse(partitionAware);
 
@@ -301,8 +297,7 @@ public void testExceptionInRetryPolicyPropagatesToCaller() {
      * Tests that setting retry policy to null effectively disables retry/failover.
      */
     @SuppressWarnings("ThrowableNotThrown")
-    @Test
-    @Ignore
+    @Test    
     public void testNullRetryPolicyDisablesFailover() {
         try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
              IgniteClient client = Ignition.startClient(getClientConfiguration()
@@ -330,8 +325,7 @@ public void testNullRetryPolicyDisablesFailover() {
      * Tests that retry limit of 1 effectively disables retry/failover.
      */
     @SuppressWarnings("ThrowableNotThrown")
-    @Test
-    @Ignore
+    @Test    
     public void testRetryNonePolicyDisablesFailover() {
         try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
              IgniteClient client = Ignition.startClient(getClientConfiguration()
@@ -358,8 +352,7 @@ public void testRetryNonePolicyDisablesFailover() {
     /**
      * Tests that {@link ClientOperationType} is updated accordingly when {@link ClientOperation} is added.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testRetryPolicyConvertOpAllOperationsSupported() {
         List<ClientOperation> nullOps = Arrays.stream(ClientOperation.values())
                 .filter(o -> o.toPublicOperationType() == null)
@@ -379,8 +372,7 @@ public void testRetryPolicyConvertOpAllOperationsSupported() {
     /**
      * Test that failover doesn't lead to silent query inconsistency.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testQueryConsistencyOnFailover() throws Exception {
         int CLUSTER_SIZE = 2;
 
@@ -418,8 +410,7 @@ public void testQueryConsistencyOnFailover() throws Exception {
     /**
      * Test that client works properly with servers txId intersection.
      */
-    @Test
-    @Ignore
+    @Test    
     @SuppressWarnings("ThrowableNotThrown")
     public void testTxWithIdIntersection() throws Exception {
         // Partition-aware client connects to all known servers at the start, and dropAllThinClientConnections
@@ -489,8 +480,7 @@ public void testTxWithIdIntersection() throws Exception {
     /**
      * Test reconnection throttling.
      */
-    @Test
-    @Ignore
+    @Test    
     @SuppressWarnings("ThrowableNotThrown")
     public void testReconnectionThrottling() throws Exception {
         // If partition awareness is enabled, channels are restored asynchronously without applying throttling.
@@ -536,8 +526,7 @@ public void testReconnectionThrottling() throws Exception {
     /**
      * Test server-side critical error.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testServerCriticalError() throws Exception {
         AtomicBoolean failure = new AtomicBoolean();
 
@@ -575,8 +564,7 @@ public void testServerCriticalError() throws Exception {
      * Test that client can invoke service method with externalizable parameter after
      * cluster failover.
      */
-    @Test
-    public void testServiceMethodInvocationAfterFailover() throws Exception {
+    @Test    public void testServiceMethodInvocationAfterFailover() throws Exception {
         PersonExternalizable person = new PersonExternalizable("Person 1");
 
         ServiceConfiguration testSrvcCfg = new ServiceConfiguration();
@@ -641,8 +629,7 @@ public void testServiceMethodInvocationAfterFailover() throws Exception {
     /**
      * Tests that server does not disconnect idle clients when heartbeats are enabled.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testServerDoesNotDisconnectIdleClientWithHeartbeats() throws Exception {
         IgniteConfiguration serverCfg = getConfiguration().setClientConnectorConfiguration(
                 new ClientConnectorConfiguration().setIdleTimeout(2000));
@@ -661,8 +648,7 @@ public void testServerDoesNotDisconnectIdleClientWithHeartbeats() throws Excepti
     /**
      * Tests service proxy failover.
      */
-    @Test
-    @Ignore
+    @Test    
     public void testServiceProxyFailover() throws Exception {
         Assume.assumeTrue(partitionAware);