|
@@ -298,7 +298,7 @@ public class MigrationAbstractServiceImpl<T> implements IMigrationAbstractServic
|
|
|
}else{
|
|
|
int count= vos.size() / MigrationConstant.BATCH_SUBMIT_DATA_COUNT;
|
|
|
for(int k = 0; k< count + 1 ;k++){
|
|
|
- int end = (k+1) * MigrationConstant.BATCH_SUBMIT_DATA_COUNT - 1;
|
|
|
+ int end = (k+1) * MigrationConstant.BATCH_SUBMIT_DATA_COUNT;
|
|
|
if(end > vos.size()){
|
|
|
end = vos.size();
|
|
|
}
|
|
@@ -409,7 +409,7 @@ public class MigrationAbstractServiceImpl<T> implements IMigrationAbstractServic
|
|
|
}else{
|
|
|
int count= syncDataList.size() / MigrationConstant.BATCH_SUBMIT_DATA_COUNT;
|
|
|
for(int k = 0; k < count + 1 ;k++){
|
|
|
- int end = (k+1) * MigrationConstant.BATCH_SUBMIT_DATA_COUNT - 1;
|
|
|
+ int end = (k+1) * MigrationConstant.BATCH_SUBMIT_DATA_COUNT;
|
|
|
if(end > syncDataList.size()){
|
|
|
end = syncDataList.size();
|
|
|
}
|