This is an automated cherry-pick of pingcap#44442

Signed-off-by: ti-chi-bot <[email protected]>

Author: tangenta

br/pkg/lightning/backend/local/duplicate.go

@@ -635,8 +635,9 @@ func (m *DupeDetector) buildIndexDupTasks() ([]dupTask, error) {
 			tid := tablecodec.DecodeTableID(ranges[0].StartKey)
 			for _, r := range ranges {
 				tasks = append(tasks, dupTask{
-					KeyRange: r,
-					tableID:  tid,
+					KeyRange:  r,
+					tableID:   tid,
+					indexInfo: indexInfo,
 				})
 			}
 		})

ddl/ingest/backend.go

@@ -224,8 +224,11 @@ func (bc *litBackendCtx) Flush(indexID int64, mode FlushMode) (flushed, imported
 	return true, true, nil
 }
 
+// ForceSyncFlagForTest is a flag to force sync only for test.
+var ForceSyncFlagForTest = false
+
 func (bc *litBackendCtx) ShouldSync(mode FlushMode) (shouldFlush bool, shouldImport bool) {
-	if mode == FlushModeForceGlobal {
+	if mode == FlushModeForceGlobal || ForceSyncFlagForTest {
 		return true, true
 	}
 	if mode == FlushModeForceLocal {

tests/realtikvtest/addindextest/BUILD.bazel

@@ -38,9 +38,13 @@ go_test(
         "//ddl",
         "//ddl/ingest",
         "//ddl/testutil",
+<<<<<<< HEAD
         "//domain",
         "//errno",
         "//parser/model",
+=======
+        "//errno",
+>>>>>>> cd0f864f714 (lightning/backend/local: fix `buildIndexDupTasks` (#44442))
         "//sessionctx/variable",
         "//testkit",
         "//tests/realtikvtest",

tests/realtikvtest/addindextest/integration_test.go

@@ -27,9 +27,13 @@ import (
 	"github.com/pingcap/tidb/ddl"
 	"github.com/pingcap/tidb/ddl/ingest"
 	"github.com/pingcap/tidb/ddl/testutil"
+<<<<<<< HEAD
 	"github.com/pingcap/tidb/domain"
 	"github.com/pingcap/tidb/errno"
 	"github.com/pingcap/tidb/parser/model"
+=======
+	"github.com/pingcap/tidb/errno"
+>>>>>>> cd0f864f714 (lightning/backend/local: fix `buildIndexDupTasks` (#44442))
 	"github.com/pingcap/tidb/sessionctx/variable"
 	"github.com/pingcap/tidb/testkit"
 	"github.com/pingcap/tidb/tests/realtikvtest"
@@ -455,6 +459,7 @@ func TestAddIndexFinishImportError(t *testing.T) {
 	require.True(t, strings.Contains(jobTp, "ingest"), jobTp)
 }
 
+<<<<<<< HEAD
 func (c *testCallback) OnJobRunAfter(job *model.Job) {
 	if c.OnJobRunAfterExported != nil {
 		c.OnJobRunAfterExported(job)
@@ -523,16 +528,32 @@ func TestAddIndexBackfillLostUpdate(t *testing.T) {
 }
 
 func TestAddIndexPreCheckFailed(t *testing.T) {
+=======
+func TestAddIndexRemoteDuplicateCheck(t *testing.T) {
+>>>>>>> cd0f864f714 (lightning/backend/local: fix `buildIndexDupTasks` (#44442))
 	store := realtikvtest.CreateMockStoreAndSetup(t)
 	tk := testkit.NewTestKit(t, store)
 	tk.MustExec("drop database if exists addindexlit;")
 	tk.MustExec("create database addindexlit;")
 	tk.MustExec("use addindexlit;")
 	tk.MustExec(`set global tidb_ddl_enable_fast_reorg=on;`)
+<<<<<<< HEAD
 
 	tk.MustExec("create table t(id int primary key, b int, k int);")
 	tk.MustExec("insert into t values (1, 1, 1);")
 	require.NoError(t, failpoint.Enable("github.com/pingcap/tidb/ddl/ingest/mockIngestCheckEnvFailed", "return"))
 	tk.MustGetErrMsg("alter table t add index idx(b);", "[ddl:8256]Check ingest environment failed: mock error")
 	require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/ddl/ingest/mockIngestCheckEnvFailed"))
+=======
+	tk.MustExec("set global tidb_ddl_reorg_worker_cnt=1;")
+
+	tk.MustExec("create table t(id int primary key, b int, k int);")
+	tk.MustQuery("split table t by (30000);").Check(testkit.Rows("1 1"))
+	tk.MustExec("insert into t values(1, 1, 1);")
+	tk.MustExec("insert into t values(100000, 1, 1);")
+
+	ingest.ForceSyncFlagForTest = true
+	tk.MustGetErrCode("alter table t add unique index idx(b);", errno.ErrDupEntry)
+	ingest.ForceSyncFlagForTest = false
+>>>>>>> cd0f864f714 (lightning/backend/local: fix `buildIndexDupTasks` (#44442))
 }