We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3bed95f commit 9fca7f4Copy full SHA for 9fca7f4
1 file changed
hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java
@@ -1247,7 +1247,10 @@ private Get createGetForIncrBackupTableSet(String backupRoot) throws IOException
1247
* @return put operation
1248
*/
1249
private Put createPutForIncrBackupTableSet(Set<TableName> tables, String backupRoot) {
1250
- Put put = new Put(rowkey(INCR_BACKUP_SET, backupRoot));
+ // added 1ms to prevent LostUpdate problem in case when deleteIncrementalBackupTableSet()
1251
+ // executed very fast
1252
+ long ts = EnvironmentEdgeManager.currentTime() + 1;
1253
+ Put put = new Put(rowkey(INCR_BACKUP_SET, backupRoot), ts);
1254
for (TableName table : tables) {
1255
put.addColumn(BackupSystemTable.META_FAMILY, Bytes.toBytes(table.getNameAsString()),
1256
EMPTY_VALUE);
0 commit comments