This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEODE-9747
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 1f49a587d0b22ee18342b4840739806a8e5db73c
Author: zhouxh <[email protected]>
AuthorDate: Mon Nov 8 16:59:08 2021 -0800

    GEODE-9747: add expected DistributedSystemDisconnectedException to the test
---
 .../partitioned/PersistentPartitionedRegionDistributedTest.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionDistributedTest.java
 
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionDistributedTest.java
index a58faf4..7ca095c 100644
--- 
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionDistributedTest.java
+++ 
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionDistributedTest.java
@@ -1681,8 +1681,9 @@ public class PersistentPartitionedRegionDistributedTest 
implements Serializable
 
   private boolean thrownByDiskRecoveryDueToConflictingPersistentDataException(
       Throwable expectedException) {
-    return expectedException instanceof CacheClosedException
-        && expectedException.getCause() instanceof 
ConflictingPersistentDataException;
+    return expectedException instanceof DistributedSystemDisconnectedException
+        || (expectedException instanceof CacheClosedException
+            && expectedException.getCause() instanceof 
ConflictingPersistentDataException);
   }
 
   private boolean 
thrownByAsyncFlusherThreadDueToConflictingPersistentDataException(

Reply via email to