Index: modules/core/src/test/java/org/apache/ignite/util/PoorPersistentTransactionTest.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- modules/core/src/test/java/org/apache/ignite/util/PoorPersistentTransactionTest.java	(revision )
+++ modules/core/src/test/java/org/apache/ignite/util/PoorPersistentTransactionTest.java	(revision )
@@ -0,0 +1,83 @@
+/*
+ * Copyright 2019 GridGain Systems, Inc. and Contributors.
+ *
+ * Licensed under the GridGain Community Edition License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.gridgain.com/products/software/community-edition/gridgain-community-edition-license
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.ignite.util;
+import java.util.Collections;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import org.apache.ignite.Ignite;
+import org.apache.ignite.cache.CacheAtomicityMode;
+import org.apache.ignite.cache.CacheServerNotFoundException;
+import org.apache.ignite.cache.affinity.Affinity;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.configuration.DataRegionConfiguration;
+import org.apache.ignite.configuration.DataStorageConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.failure.StopNodeFailureHandler;
+import org.apache.ignite.spi.discovery.DiscoverySpi;
+import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
+import org.apache.ignite.testframework.GridTestUtils;
+import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.apache.ignite.transactions.Transaction;
+import org.junit.Assert;
+import org.junit.Test;
+public class PoorPersistentTransactionTest extends GridCommonAbstractTest {
+    @Test
+    public void startNode() throws Exception {
+        try (Ignite ign =  startGrid(config("instanzz0"))) {
+            TimeUnit.SECONDS.sleep(50000);
+        }
+    }
+    @Test
+    public void poorTransaction() throws Exception {
+        try (Ignite ign = startGrid(config("instanzz1").setClientMode(false))) {
+            ign.active(true);
+            int key1 = 0;
+            int key2 = 1;
+
+            Thread.sleep(3_000);
+
+            Affinity<Object> aff = ign.affinity("cache");
+            assert !aff.mapKeyToNode(key1).equals(aff.mapKeyToNode(key2));
+            try (Transaction tx = ign.transactions().txStart()) {
+                ign.cache("cache").put(key1, 100);
+                ign.cache("cache").put(key2, 200);
+                tx.commit();
+            }
+            startGrid(config("instanzz0").setClientMode(false));
+            Assert.assertEquals(100, ign.cache("cache").get(key1));
+            Assert.assertEquals(null, ign.cache("cache").get(key2));
+//
+//            GridTestUtils.assertThrows(null, () -> {
+//                ign.cache("cache").get(key2);
+//            }, CacheServerNotFoundException.class, null);
+        }
+    }
+    private IgniteConfiguration config(String name) {
+        DiscoverySpi discoSpi = new TcpDiscoverySpi()
+            .setIpFinder(new TcpDiscoveryVmIpFinder()
+                .setAddresses(Collections.singleton("localhost:47500..47509")));
+        DataStorageConfiguration dsConfig = new DataStorageConfiguration()
+            .setDefaultDataRegionConfiguration(new DataRegionConfiguration()
+                .setPersistenceEnabled(true));
+        return new IgniteConfiguration()
+            .setDiscoverySpi(discoSpi)
+            .setIgniteInstanceName(name)
+            .setConsistentId(name)
+            .setDataStorageConfiguration(dsConfig)
+            .setCacheConfiguration(new CacheConfiguration("cache").setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL));
+    }
+}
\ No newline at end of file
Index: modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java	(revision 62d7df43b67045c90bbb4ee6c313fd452bc37e46)
+++ modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java	(revision )
@@ -1454,6 +1454,9 @@
 
         boolean intercept = cctx.config().getInterceptor() != null;
 
+        if (Thread.currentThread().getName().contains("instanzz0"))
+            throw new IgniteException("e");
+
         Object key0 = null;
         Object val0 = null;
         WALPointer logPtr = null;