From 6c223383de6944d2ae4c79627439946046d6867f Mon Sep 17 00:00:00 2001
From: jaredhu <jaredhu@vip.qq.com>
Date: Wed, 19 Apr 2017 15:58:31 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E6=97=A5=E5=BF=97=E6=9F=A5?=
 =?UTF-8?q?=E8=AF=A2realTaskId=E5=A4=B1=E6=95=88=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修正日志查询realTaskId失效问题
---
 .../github/ltsopensource/biz/logger/mongo/MongoJobLogger.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/lts-core/src/main/java/com/github/ltsopensource/biz/logger/mongo/MongoJobLogger.java b/lts-core/src/main/java/com/github/ltsopensource/biz/logger/mongo/MongoJobLogger.java
index f29d659f9..874124302 100644
--- a/lts-core/src/main/java/com/github/ltsopensource/biz/logger/mongo/MongoJobLogger.java
+++ b/lts-core/src/main/java/com/github/ltsopensource/biz/logger/mongo/MongoJobLogger.java
@@ -53,6 +53,9 @@ public PaginationRsp<JobLogPo> search(JobLoggerRequest request) {
         if(StringUtils.isNotEmpty(request.getTaskId())){
             query.field("taskId").equal(request.getTaskId());
         }
+        if(StringUtils.isNotEmpty(request.getRealTaskId())){
+            query.field("realTaskId").equal(request.getRealTaskId());
+        }   
         if(StringUtils.isNotEmpty(request.getTaskTrackerNodeGroup())){
             query.field("taskTrackerNodeGroup").equal(request.getTaskTrackerNodeGroup());
         }