Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java (revision 1022733) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java (working copy) @@ -146,21 +146,8 @@ this.metrics.appliedBatchesRate.inc(1); LOG.info("Total replicated: " + totalReplicated); } catch (IOException ex) { - if (ex.getCause() instanceof TableNotFoundException) { - LOG.warn("Losing edits because: ", ex); - } else { - // Should we log rejected edits in a file for replay? - LOG.error("Unable to accept edit because", ex); - this.stopper.stop("Unable to accept edit because " + ex.getMessage()); - throw ex; - } - } catch (RuntimeException re) { - if (re.getCause() instanceof TableNotFoundException) { - LOG.warn("Losing edits because: ", re); - } else { - this.stopper.stop("Replication stopped us because " + re.getMessage()); - throw re; - } + LOG.error("Unable to accept edit because:", ex); + throw ex; } }