[Fix][Connector-V2] Fix StarRocksCatalogTest#testCatalog() NPE (#8987)

Author: xiaochen-zhou

seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java

@@ -52,8 +52,8 @@ public class StarRocksStreamLoadVisitor {
     private static final String RESULT_FAILED = "Fail";
     private static final String RESULT_SUCCESS = "Success";
     private static final String RESULT_LABEL_EXISTED = "Label Already Exists";
-    private static final String LAEBL_STATE_VISIBLE = "VISIBLE";
-    private static final String LAEBL_STATE_COMMITTED = "COMMITTED";
+    private static final String LABEL_STATE_VISIBLE = "VISIBLE";
+    private static final String LABEL_STATE_COMMITTED = "COMMITTED";
     private static final String RESULT_LABEL_PREPARE = "PREPARE";
     private static final String RESULT_LABEL_ABORTED = "ABORTED";
     private static final String RESULT_LABEL_UNKNOWN = "UNKNOWN";
@@ -225,8 +225,8 @@ private void checkLabelState(String host, String label) throws IOException {
                 }
                 LOG.info(String.format("Checking label[%s] state[%s]\n", label, labelState));
                 switch (labelState) {
-                    case LAEBL_STATE_VISIBLE:
-                    case LAEBL_STATE_COMMITTED:
+                    case LABEL_STATE_VISIBLE:
+                    case LABEL_STATE_COMMITTED:
                         return;
                     case RESULT_LABEL_PREPARE:
                         continue;

seatunnel-connectors-v2/connector-starrocks/src/test/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalogTest.java

@@ -421,6 +421,13 @@ public void testCatalog() {
                         String.format(URL, starRocksServer.getHost()),
                         "CREATE TABLE IF NOT EXISTS `${database}`.`${table}` (\n ${rowtype_fields}\n ) ENGINE=OLAP \n  DUPLICATE KEY(`BIGINT_COL`) \n COMMENT '${comment}' \n DISTRIBUTED BY HASH (BIGINT_COL) BUCKETS 1 \n PROPERTIES (\n   \"replication_num\" = \"1\", \n  \"in_memory\" = \"false\" , \n  \"storage_format\" = \"DEFAULT\"  \n )");
         starRocksCatalog.open();
+
+        String tmpDB = "test_tmp";
+        if (!starRocksCatalog.databaseExists(tmpDB)) {
+            starRocksCatalog.createDatabase(TablePath.of(tmpDB, "default"), true);
+        }
+        Assertions.assertTrue(starRocksCatalog.listDatabases().contains(tmpDB));
+
         CatalogTable catalogTable = starRocksCatalog.getTable(tablePathStarRocksSource);
         catalogTable =
                 CatalogTable.of(