Merge branch 'release-v2.0.4' of https://github.com/tapdata/tapdata-connectors into release-v2.0.4

Author: ply0011

connectors-common/mysql-core/src/main/java/io/tapdata/connector/mysql/MysqlReaderV2.java

@@ -104,6 +104,7 @@ public void startMiner(Supplier<Boolean> isAlive) throws Throwable {
                     handleTableMapEvent(event);
                 } else if (eventType == EventType.QUERY) {
                     concurrentProcessor.runAsyncWithBlocking(new ScanEvent(event, currentBinlogFile.get()), this::emit);
+                    return;
                 }
 
                 // 异步处理事件

connectors/starrocks-connector/src/main/java/io/tapdata/connector/starrocks/StarrocksTest.java

@@ -127,9 +127,9 @@ public Boolean testStreamLoadPrivilege() {
                 HttpGet httpGet = new HttpGet();
                 httpGet.setURI(new URI("https://" + ((StarrocksConfig) commonDbConfig).getStarrocksHttp()));
                 httpGet.setHeader("Authorization", authHeader);
-                testResult = EntityUtils.toString(client.execute(httpGet).getEntity()).contains("starrocks");
+                testResult = EntityUtils.toString(client.execute(httpGet).getEntity()).toLowerCase().contains("starrocks");
             } else {
-                testResult = HttpRequest.get("http://" + ((StarrocksConfig) commonDbConfig).getStarrocksHttp()).header("Authorization", authHeader).execute().body().contains("starrocks");
+                testResult = HttpRequest.get("http://" + ((StarrocksConfig) commonDbConfig).getStarrocksHttp()).header("Authorization", authHeader).execute().body().toLowerCase().contains("starrocks");
             }
 
             if (testResult) {