Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Revert "HBASE-21507 Compaction failed when execute AbstractMultiFileWriter.beforeShipped() method"

Browse Source 
This reverts commit 6aa57f71f0e266fba96066da7e8562d00daef5a8.
This commit is contained in:
zhangduo 2018-11-27 20:58:14 +08:00
parent 6aa57f71f0
commit beeb38d4dc
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMultiFileWriter.java
View File

@ -21,10 +21,12 @@ 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;
/**
* Base class for cell sink that separates the provided cells into multiple files.
@ -117,12 +119,9 @@ public abstract class AbstractMultiFileWriter implements CellSink, ShipperListen
@Override
public void beforeShipped() throws IOException {
Collection<StoreFileWriter> writers = writers();
if (writers != null) {
for (StoreFileWriter writer : writers) {
if (writer != null) {
writer.beforeShipped();
}
if (this.writers() != null) {
for (StoreFileWriter writer : writers()) {
writer.beforeShipped();
}
}
}