diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMultiFileWriter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMultiFileWriter.java index 2fdab81313..306f35c563 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMultiFileWriter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMultiFileWriter.java @@ -17,16 +17,15 @@ */ package org.apache.hadoop.hbase.regionserver; -import java.io.IOException; -import java.util.ArrayList; -import java.util.Collection; -import java.util.List; - import org.apache.hadoop.fs.Path; import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.hbase.regionserver.CellSink; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; /** * Base class for cell sink that separates the provided cells into multiple files. @@ -121,7 +120,9 @@ public abstract class AbstractMultiFileWriter implements CellSink, ShipperListen public void beforeShipped() throws IOException { if (this.writers() != null) { for (StoreFileWriter writer : writers()) { - writer.beforeShipped(); + if(writer != null) { + writer.beforeShipped(); + } } } }