Index: modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImplSelfTest.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImplSelfTest.java	(revision 68461d07b6d1aea49e2c1548967386d30f69181b)
+++ modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImplSelfTest.java	(date 1594911061865)
@@ -60,6 +60,7 @@
 import org.junit.Test;
 
 import static org.apache.ignite.cache.CacheMode.PARTITIONED;
+import static org.apache.ignite.cache.CacheMode.REPLICATED;
 import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
 import static org.apache.ignite.spi.communication.tcp.internal.TcpConnectionIndexAwareMessage.UNDEFINED_CONNECTION_INDEX;
 
@@ -96,7 +97,7 @@
         cfg.setCommunicationSpi(new StaleTopologyCommunicationSpi());
 
         if (cnt < MAX_CACHE_COUNT)
-            cfg.setCacheConfiguration(cacheConfiguration());
+            cfg.setCacheConfiguration(cacheConfiguration().setCacheMode(REPLICATED));
 
         cnt++;
 
@@ -294,12 +295,13 @@
      * @throws Exception If failed.
      */
     @Test
-    @Ignore("https://ggsystems.atlassian.net/browse/GG-29798")
     public void testAllOperationFinishedBeforeFutureCompletion() throws Exception {
         cnt = 0;
 
         Ignite ignite = startGrids(MAX_CACHE_COUNT);
 
+        awaitPartitionMapExchange();
+
         final IgniteCache cache = ignite.cache(DEFAULT_CACHE_NAME);
         final CountDownLatch latch = new CountDownLatch(1);
         final AtomicReference<Throwable> ex = new AtomicReference<>();