From 6fdf6df9c3795bb8e2bc8860acbd784885560437 Mon Sep 17 00:00:00 2001
From: huanghai <10402852@qq.com>
Date: Mon, 7 Sep 2020 10:06:08 +0800
Subject: [PATCH] 'commit'

---
 .../ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go
index 1da42dfb..6372c0e0 100644
--- a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go
+++ b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go
@@ -108,6 +108,9 @@ func main() {
 				break
 			}
 			//批量执行
+			if len(pkStrArray) == 0 { //应该是有错误的数据，导致拿不到结果
+				continue
+			}
 			batchSave(indexName, pk)
 		}
 		fmt.Println("索引" + indexName + "同步完成！")
@@ -177,9 +180,6 @@ func addRecord(pk string, jsonStr string) {
 func batchSave(tableName string, pkName string) {
 	var pkStr = ""
 	//数组去重
-	if len(pkStrArray) == 0 { //应该是有错误的数据，导致拿不到结果
-		return
-	}
 	pkStrArray = CommonUtil.RemoveRepeatedElement(pkStrArray)
 	for i := range pkStrArray {
 		pkStr += "'" + pkStrArray[i] + "',"