diff --git a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java index 14a43fe7..38aedc3d 100644 --- a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java +++ b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java @@ -625,7 +625,7 @@ private void compatOldServerBatch(final List actions, final Objec @Override public void batch(final List actions, final Object[] results) throws IOException { - if (actions == null) { + if (actions == null || actions.isEmpty()) { return; } if (results != null) { @@ -725,7 +725,7 @@ private String getTargetTableName(List actions) { if (action instanceof RowMutations || action instanceof RegionCoprocessorServiceExec) { throw new FeatureNotSupportedException("not supported yet'"); } else { - Set familySet; + Set familySet = null; if (action instanceof Get) { Get get = (Get) action; familySet = get.familySet();