Logs duplicate token account association and token balance (#3849)

Signed-off-by: Xin Li <xin.li@swirldslabs.com>
hashgraph · May 24, 2022 · 4ed267f · 4ed267f
1 parent e59776f
commit 4ed267f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...ter/src/main/java/com/hedera/mirror/importer/parser/balance/AccountBalanceFileParser.java b/...ter/src/main/java/com/hedera/mirror/importer/parser/balance/AccountBalanceFileParser.java
@@ -94,7 +94,9 @@ protected void doParse(AccountBalanceFile accountBalanceFile) {
             count = accountBalanceFile.getItems().doOnNext(accountBalance -> {
                 accountBalances.add(accountBalance);
                 for (var tokenBalance : accountBalance.getTokenBalances()) {
-                    tokenBalances.put(tokenBalance.getId(), tokenBalance);
+                    if (tokenBalances.putIfAbsent(tokenBalance.getId(), tokenBalance) != null) {
+                        log.warn("Skipping duplicate token balance: {}", tokenBalance);
+                    }
                 }
 
                 if (accountBalances.size() >= batchSize) {

diff --git a/.../src/main/java/com/hedera/mirror/importer/parser/record/entity/sql/SqlEntityListener.java b/.../src/main/java/com/hedera/mirror/importer/parser/record/entity/sql/SqlEntityListener.java
@@ -403,6 +403,7 @@ public void onToken(Token token) throws ImporterException {
     @Override
     public void onTokenAccount(TokenAccount tokenAccount) throws ImporterException {
         if (tokenAccounts.containsKey(tokenAccount.getId())) {
+            log.warn("Skipping duplicate token account association: {}", tokenAccount);
             return;
         }