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

HBASE-24856 Fix error prone error in FlushTableSubprocedure (#2242)

Browse Source 
Signed-off-by: Viraj Jasani <vjasani@apache.org>
Signed-off-by: Jan Hentschel <jan.hentschel@ultratendency.com>
This commit is contained in:
Duo Zhang 2020-08-12 09:51:12 +08:00
parent 8737afb01e
commit 96ea136a8e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/flush/FlushTableSubprocedure.java
View File

@ -18,6 +18,7 @@
package org.apache.hadoop.hbase.procedure.flush; package org.apache.hadoop.hbase.procedure.flush;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
@ -102,7 +103,7 @@ public class FlushTableSubprocedure extends Subprocedure {
List<byte[]> families = null; List<byte[]> families = null;
if (family != null) { if (family != null) {
LOG.debug("About to flush family {} on all regions for table {}", family, table); LOG.debug("About to flush family {} on all regions for table {}", family, table);
families = Arrays.asList(Bytes.toBytes(family)); families = Collections.singletonList(Bytes.toBytes(family));
} }
// Add all hfiles already existing in region. // Add all hfiles already existing in region.
for (HRegion region : regions) { for (HRegion region : regions) {