From 3e17c984eb3e72fa6461f142d7fd8ea591bef20d Mon Sep 17 00:00:00 2001 From: mohitdeuex Date: Thu, 27 Jul 2023 12:09:01 +0530 Subject: [PATCH] added list to ignore migration if already done for --- .../org/openmetadata/service/migration/MigrationUtil.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/migration/MigrationUtil.java b/openmetadata-service/src/main/java/org/openmetadata/service/migration/MigrationUtil.java index 65cc87a1df3..05d20fc7ba0 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/migration/MigrationUtil.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/migration/MigrationUtil.java @@ -310,6 +310,11 @@ public class MigrationUtil { private static void updateFQNHashEntityExtensionTimeSeries( Handle handle, String updateSql, CollectionDAO collectionDAO, int limitParam) { LOG.debug("Starting Migration for Entity Extension Time Series"); + try { + collectionDAO.entityExtensionTimeSeriesDao().listDistinctCount(); + } catch (Exception ex) { + return; + } while (true) { PreparedBatch upsertBatch = handle.prepareBatch(updateSql); List entityFQNLists =