yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-20 06:58:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix 172 migrations by avoiding throwing errors (#21697)

Browse Source
This commit is contained in:
IceS2 2025-06-12 23:49:26 +02:00 committed by GitHub
parent 2803e62f0b
commit a3968d40b0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
openmetadata-service/src/main/java/org/openmetadata/service/migration/utils/v172/MigrationUtil.java
View File

@ -34,10 +34,8 @@ public class MigrationUtil {
deleteIndexTemplate(searchClient); deleteIndexTemplate(searchClient);
deleteComponentTemplate(searchClient); deleteComponentTemplate(searchClient);
deleteIlmPolicy(searchClient, null); deleteIlmPolicy(searchClient, null);
LOG.info("Successfully completed Data Insights objects cleanup");
} catch (Exception e) { } catch (Exception e) {
LOG.error("Error deleting Data Insights objects", e); LOG.error("Error deleting Data Insights objects", e);
throw e;
} }
} else { } else {
LOG.info("No CLUSTER_ALIAS found, skipping cleanup"); LOG.info("No CLUSTER_ALIAS found, skipping cleanup");
@ -72,7 +70,6 @@ public class MigrationUtil {
} }
} catch (Exception e) { } catch (Exception e) {
LOG.error("Error deleting data insights data streams", e); LOG.error("Error deleting data insights data streams", e);
throw e;
} }
} }
@ -87,7 +84,6 @@ public class MigrationUtil {
searchClient.deleteILMPolicy(getClusteredPrefix(clusterAlias, ILM_POLICY_NAME)); searchClient.deleteILMPolicy(getClusteredPrefix(clusterAlias, ILM_POLICY_NAME));
} catch (Exception e) { } catch (Exception e) {
LOG.error("Error deleting ILM policies", e); LOG.error("Error deleting ILM policies", e);
throw e;
} }
} }
@ -97,7 +93,6 @@ public class MigrationUtil {
searchClient.deleteIndexTemplate(INDEX_TEMPLATE_NAME); searchClient.deleteIndexTemplate(INDEX_TEMPLATE_NAME);
} catch (Exception e) { } catch (Exception e) {
LOG.error("Error deleting index template", e); LOG.error("Error deleting index template", e);
throw e;
} }
} }
@ -108,7 +103,6 @@ public class MigrationUtil {
searchClient.deleteComponentTemplate(componentName); searchClient.deleteComponentTemplate(componentName);
} catch (Exception e) { } catch (Exception e) {
LOG.error("Error deleting component template", e); LOG.error("Error deleting component template", e);
throw e;
} }
} }
} }