From 9a93c3d3302f0c765bf9849b5c7c5cacad74a33d Mon Sep 17 00:00:00 2001
From: zhangxin <Xin.zhang@le-it.com.cn>
Date: Mon, 12 Jul 2021 15:50:30 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BC=A0=E5=8F=82=E7=9A=84?=
 =?UTF-8?q?=E5=BD=A2=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 scheduler/extract.go | 2 +-
 scheduler/trigger.go | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/scheduler/extract.go b/scheduler/extract.go
index 760f63c..d6e1e6d 100644
--- a/scheduler/extract.go
+++ b/scheduler/extract.go
@@ -22,7 +22,7 @@ func ETLExtract() {
 	for _, task := range taskLi {
 		for _, trigger := range task.TriggerLi {
 			if trigger.TriggerType == model.TRIGGER_TYPE_TIME {
-				go ExtractTrigger(&trigger, &task)
+				go ExtractTrigger(trigger, task)
 			}
 		}
 	}
diff --git a/scheduler/trigger.go b/scheduler/trigger.go
index 52427de..4756948 100644
--- a/scheduler/trigger.go
+++ b/scheduler/trigger.go
@@ -7,7 +7,7 @@ import (
 	"time"
 )
 
-func ExtractTrigger(triggerConfig *model.Trigger, task *model.TaskHead) {
+func ExtractTrigger(triggerConfig model.Trigger, task model.TaskHead) {
 	global.TaskExtractStatusMap.Lock.Lock()
 	_, exist := global.TaskExtractStatusMap.Map[triggerConfig.TaskId]
 	if !exist {
@@ -36,7 +36,7 @@ func ExtractTrigger(triggerConfig *model.Trigger, task *model.TaskHead) {
 		}
 	}
 	extractService := svr.NewExtractService()
-	extractService.StandardExtract(task)
+	extractService.StandardExtract(&task)
 	global.ETLTaskRecord.TaskMap[triggerConfig.TaskId] = time.Now()
 }