HBASE-27247 TestPerTableCFReplication.testParseTableCFsFromConfig is …

…broken because of ReplicationPeerConfigUtil.parseTableCFsFromConfig (#4658) Co-authored-by: comnetwork <[email protected]> Signed-off-by: Duo Zhang <[email protected]>
apache · Jul 28, 2022 · 95a2e59 · 95a2e59
1 parent 6a169b5
commit 95a2e59
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...t/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationPeerConfigUtil.java b/...t/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationPeerConfigUtil.java
@@ -124,7 +124,13 @@ public static ReplicationProtos.TableCF[] convert(String tableCFsConfig) {
       }
       // 2 split to "table" and "cf1,cf2"
       // for each table: "table#cf1,cf2" or "table"
-      Iterator<String> i = Splitter.on(':').split(tab).iterator();
+      List<String> pair = Splitter.on(':').splitToList(tab);
+      if (pair.size() > 2) {
+        LOG.info("incorrect format:" + tableCFsConfig);
+        continue;
+      }
+      assert pair.size() > 0;
+      Iterator<String> i = pair.iterator();
       String tabName = i.next().trim();
       if (tabName.length() == 0) {
         LOG.info("incorrect format:" + tableCFsConfig);