ignore duplicate key error when in full sync stage3. #579

alibaba · Apr 12, 2021 · 4a7237e · 4a7237e
1 parent cb6919d
commit 4a7237e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/executor/db_writer_test.go b/executor/db_writer_test.go
@@ -149,7 +149,7 @@ func TestSingleWriter(t *testing.T) {
 		conn, err := utils.NewMongoConn(testMongoAddress, "primary", true, utils.ReadWriteConcernDefault, utils.ReadWriteConcernDefault, "")
 		assert.Equal(t, nil, err, "should be equal")
 
-		writer := NewDbWriter(conn.Session, bson.M{}, false, 0)
+		writer := NewDbWriter(conn.Session, bson.M{}, false, 1)
 
 		// drop database
 		err = conn.Session.DB(testDb).DropDatabase()
@@ -190,7 +190,6 @@ func TestSingleWriter(t *testing.T) {
 			assert.Equal(t, true, result[0].(bson.M)["x"] == 10, "should be equal")
 		}
 	}
-	return
 
 	// test upsert, dupInsert
 	{