From 5cf7b54407bf044baaa5258a6ea5f7dda54584b3 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 (cherry picked from commit 3e17c984eb3e72fa6461f142d7fd8ea591bef20d) --- .../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 4abc06b184f1..11cfb37096a9 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 @@ private static void updateFQNHashForFieldRelationship( 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 =