Index: hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java (revision 1360036) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java (working copy) @@ -101,6 +101,7 @@ import org.apache.hadoop.hbase.replication.regionserver.Replication; import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.hbase.util.CompressionTest; import org.apache.hadoop.hbase.util.FSTableDescriptors; import org.apache.hadoop.hbase.util.HasThread; import org.apache.hadoop.hbase.util.InfoServer; @@ -1376,6 +1377,10 @@ HRegionInfo [] newRegions = getHRegionInfos(hTableDescriptor, splitKeys); checkInitialized(); + for (HColumnDescriptor hcd : hTableDescriptor.getColumnFamilies()) { + CompressionTest.testCompression(hcd.getCompression()); + CompressionTest.testCompression(hcd.getCompactionCompression()); + } if (cpHost != null) { cpHost.preCreateTable(hTableDescriptor, newRegions); } @@ -1505,6 +1510,8 @@ try { checkInitialized(); + CompressionTest.testCompression(descriptor.getCompression()); + CompressionTest.testCompression(descriptor.getCompactionCompression()); if (cpHost != null) { if (cpHost.preModifyColumn(tableName, descriptor)) { return ModifyColumnResponse.newBuilder().build(); @@ -1626,6 +1633,10 @@ HTableDescriptor htd = HTableDescriptor.convert(req.getTableSchema()); try { checkInitialized(); + for (HColumnDescriptor hcd : htd.getColumnFamilies()) { + CompressionTest.testCompression(hcd.getCompression()); + CompressionTest.testCompression(hcd.getCompactionCompression()); + } if (cpHost != null) { cpHost.preModifyTable(tableName, htd); }