polish

alibaba · Oct 31, 2024 · 59d814d · 59d814d
1 parent 095d89c
commit 59d814d
Show file tree

Hide file tree

Showing 9 changed files with 18 additions and 1,424 deletions.
diff --git a/core/pipeline/Pipeline.cpp b/core/pipeline/Pipeline.cpp
@@ -388,6 +388,10 @@ bool Pipeline::Send(vector<PipelineEventGroup>&& groupList) {
     auto before = chrono::system_clock::now();
     bool allSucceeded = true;
     for (auto& group : groupList) {
+        if (group.GetEvents().empty()) {
+            LOG_DEBUG(sLogger, ("empty event group", "discard")("config", mName));
+            continue;
+        }
         auto res = mRouter.Route(group);
         for (auto& item : res) {
             if (item.first >= mFlushers.size()) {

diff --git a/core/plugin/flusher/sls/FlusherSLS.cpp b/core/plugin/flusher/sls/FlusherSLS.cpp
@@ -486,7 +486,11 @@ bool FlusherSLS::Init(const Json::Value& config, Json::Value& optionalGoPipeline
         mCompressor = CompressorFactory::GetInstance()->Create(config, *mContext, sName, mPluginID, CompressType::LZ4);
     }
 
+#ifdef __ENTERPRISE__
+    mGroupSerializer = make_unique<EnterpriseSLSEventGroupSerializer>(this);
+#else
     mGroupSerializer = make_unique<SLSEventGroupSerializer>(this);
+#endif
     mGroupListSerializer = make_unique<SLSEventGroupListSerializer>(this);
 
     // MaxSendRate