cleanup

Author: ffffwh

README.md

@@ -27,7 +27,7 @@ for details on submitting patches and the contribution workflow.
 
 ## Contact us
 
-*dtle* has enterprise support plan, you may contact our sales team: 
+*dtle* has an enterprise support plan. You may contact our sales team: 
 * Global Sales: 400-820-6580
 * North China: 86-13718877200, Mr.Wang
 * South China: 86-18503063188, Mr.Cao

driver/mysql/applier_incr.go

@@ -282,6 +282,7 @@ func (a *ApplierIncr) handleEntry(entryCtx *common.EntryContext) (err error) {
 		if err != nil {
 			return errors.Wrapf(err, "rollback on resent big tx")
 		}
+		// let WaitForAllCommitted() pass
 		a.mtsManager.lastEnqueue = 0
 		a.inBigTx = false
 	}

driver/state.go

@@ -4,8 +4,6 @@ import (
 	"fmt"
 	"strings"
 	"sync"
-
-	"github.com/actiontech/dtle/driver/common"
 )
 
 type taskStore struct {
@@ -58,32 +56,6 @@ func (ts *TaskStoreForApi) Set(allocId, taskName, taskId string, handle *taskHan
 	ts.store[key] = handle
 }
 
-// it can only use allocId and taskName to identify the task from http api
-func (ts *TaskStoreForApi) GetTaskStatistics(allocId, taskName string) (*common.TaskStatistics, bool, error) {
-	ts.lock.RLock()
-	defer ts.lock.RUnlock()
-
-	prefix := fmt.Sprintf("%v-%v-", allocId, taskName)
-	for k, _ := range ts.store {
-		if strings.HasPrefix(k, prefix) {
-			t, ok := ts.store[k]
-
-			var stats *common.TaskStatistics
-			if t.runner != nil {
-				var err error
-				stats, err = t.runner.Stats()
-				if nil != err {
-					return nil, false, fmt.Errorf("get stats from taskHandle failed: %v", err)
-				}
-			} else {
-				stats = &common.TaskStatistics{}
-			}
-			return stats, ok, nil
-		}
-	}
-	return nil, false, nil
-}
-
 func (ts *TaskStoreForApi) Delete(id string) {
 	ts.lock.Lock()
 	defer ts.lock.Unlock()