feat:support auth.

Author: SkyeBeFreeman

polaris-plugins/polaris-plugins-connector/connector-composite/src/main/java/com/tencent/polaris/plugins/connector/composite/CompositeServiceUpdateTask.java

@@ -111,9 +111,11 @@ public void execute() {
                 isServiceUpdateTaskExecuted = true;
                 entry.getValue().setStatus(ServiceUpdateTaskConstant.Status.READY, ServiceUpdateTaskConstant.Status.RUNNING);
                 entry.getValue().execute(this);
+            } else if (alreadyExecute(entry.getKey(), entry.getValue())) {
+                // for ExpirePendingTaskCleaner
+                isServiceUpdateTaskExecuted = true;
             }
         }
-        // TODO 全部规则实现完后改成StringUtils.equals(mainConnectorType, SERVER_CONNECTOR_CONSUL)
         if (ifMainConnectorTypeSet && isServiceUpdateTaskExecuted
                 && (StringUtils.equals(mainConnectorType, SERVER_CONNECTOR_GRPC)
                 || (serviceEventKey.getEventType().equals(EventType.INSTANCE)
@@ -417,6 +419,14 @@ private boolean canExecute(String connectorType, ServiceUpdateTask serviceUpdate
         return canConnectorExecute && canTaskExecute;
     }
 
+    private boolean alreadyExecute(String connectorType, ServiceUpdateTask serviceUpdateTask) {
+        boolean canConnectorExecute = StringUtils.equalsIgnoreCase(mainConnectorType, connectorType)
+                || serviceEventKey.getEventType().equals(EventType.INSTANCE)
+                || serviceEventKey.getEventType().equals(EventType.SERVICE);
+        boolean alreadyTaskExecute = serviceUpdateTask.getTaskStatus() == Status.RUNNING;
+        return canConnectorExecute && alreadyTaskExecute;
+    }
+
     public boolean notifyServerEventWithRevisionChecking(ServerEvent serverEvent, String revision) {
         if (serverEvent.getValue() instanceof DiscoverResponse) {
             if (StringUtils.equals(revision, instanceListMeta.getLastRevision())) {