Skip to content

Commit

Permalink
Fixed the bug that a pre-updated table may face multiple updates and …
Browse files Browse the repository at this point in the history
…generate NPE
  • Loading branch information
Caideyipi authored Nov 28, 2024
1 parent 7806f84 commit aaa9a9b
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -338,6 +338,7 @@ private void updateTable(
final Pair<TsTable, Long> existingPair =
preUpdateTableMap.get(database).get(tableName);
if (Objects.isNull(existingPair)
|| Objects.isNull(existingPair.getLeft())
|| !Objects.equals(
existingPair.getRight(),
previousVersions.get(database).get(tableName))) {
Expand Down

0 comments on commit aaa9a9b

Please sign in to comment.