allow empty endpoint in enterprise flusher_sls to avoid unsuccessful …

…load of config (#1486)
alibaba · May 16, 2024 · d5fa94c · d5fa94c
1 parent ddb5b86
commit d5fa94c
Showing 1 changed file with 27 additions and 13 deletions.
diff --git a/core/flusher/FlusherSLS.cpp b/core/flusher/FlusherSLS.cpp
@@ -94,19 +94,33 @@ bool FlusherSLS::Init(const Json::Value& config, Json::Value& optionalGoPipeline
         }
 
         // Endpoint
-        if (!GetMandatoryStringParam(config, "Endpoint", mEndpoint, errorMsg)) {
-            PARAM_ERROR_RETURN(mContext->GetLogger(),
-                               mContext->GetAlarm(),
-                               errorMsg,
-                               sName,
-                               mContext->GetConfigName(),
-                               mContext->GetProjectName(),
-                               mContext->GetLogstoreName(),
-                               mContext->GetRegion());
-        }
-        mEndpoint = TrimString(mEndpoint);
-        if (!mEndpoint.empty()) {
-            Sender::Instance()->AddEndpointEntry(mRegion, StandardizeEndpoint(mEndpoint, mEndpoint));
+#ifdef __ENTERPRISE__
+        if (!GetOptionalStringParam(config, "Endpoint", mEndpoint, errorMsg)) {
+            PARAM_WARNING_IGNORE(mContext->GetLogger(),
+                                 mContext->GetAlarm(),
+                                 errorMsg,
+                                 sName,
+                                 mContext->GetConfigName(),
+                                 mContext->GetProjectName(),
+                                 mContext->GetLogstoreName(),
+                                 mContext->GetRegion());
+        } else {
+#else
+    if (!GetMandatoryStringParam(config, "Endpoint", mEndpoint, errorMsg)) {
+        PARAM_ERROR_RETURN(mContext->GetLogger(),
+                           mContext->GetAlarm(),
+                           errorMsg,
+                           sName,
+                           mContext->GetConfigName(),
+                           mContext->GetProjectName(),
+                           mContext->GetLogstoreName(),
+                           mContext->GetRegion());
+    } else {
+#endif
+            mEndpoint = TrimString(mEndpoint);
+            if (!mEndpoint.empty()) {
+                Sender::Instance()->AddEndpointEntry(mRegion, StandardizeEndpoint(mEndpoint, mEndpoint));
+            }
         }
 #ifdef __ENTERPRISE__
     }