From 29fb52b5d213991b20df8b2daed9bd2d26f5b741 Mon Sep 17 00:00:00 2001
From: stack <stack@apache.org>
Date: Fri, 7 Feb 2020 14:27:45 -0800
Subject: [PATCH] HBASE-23812 [Flakey Test]
 TestReplicator#testReplicatorWithErrors: AssertionError: We did not replicate
 enough rows expected:<10> but was:<7>

---
 .../regionserver/HBaseInterClusterReplicationEndpoint.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
index 83918c93735..efd742d2576 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
@@ -357,8 +357,8 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
       } catch (InterruptedException ie) {
         iox = new IOException(ie);
       } catch (ExecutionException ee) {
-        // cause must be an IOException
-        iox = (IOException) ee.getCause();
+        iox = ee.getCause() instanceof IOException?
+          (IOException)ee.getCause(): new IOException(ee.getCause());
       }
     }
     if (iox != null) {