Skip to content

A
atlas
Commit 232e5962 by apoorvnaik Committed by Madhan Neethiraj
Options

ATLAS-1649: Config fix for delete handler

Signed-off-by: 's avatarMadhan Neethiraj <madhan@apache.org>
parent f673eba4
Showing with 2 additions and 1 deletion
repository/src/main/java/org/apache/atlas/util/AtlasRepositoryConfiguration.java
...@@ -94,6 +94,7 @@ public class AtlasRepositoryConfiguration { ...@@ -94,6 +94,7 @@ public class AtlasRepositoryConfiguration {
} }
private static final String DELETE_HANDLER_IMPLEMENTATION_PROPERTY = "atlas.DeleteHandler.impl"; private static final String DELETE_HANDLER_IMPLEMENTATION_PROPERTY = "atlas.DeleteHandler.impl";
private static final String DELETE_HANDLER_V1_IMPLEMENTATION_PROPERTY = "atlas.DeleteHandlerV1.impl";
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public static Class<? extends DeleteHandler> getDeleteHandlerImpl() { public static Class<? extends DeleteHandler> getDeleteHandlerImpl() {
...@@ -110,7 +111,7 @@ public class AtlasRepositoryConfiguration { ...@@ -110,7 +111,7 @@ public class AtlasRepositoryConfiguration {
try { try {
Configuration config = ApplicationProperties.get(); Configuration config = ApplicationProperties.get();
return ApplicationProperties.getClass(config, return ApplicationProperties.getClass(config,
DELETE_HANDLER_IMPLEMENTATION_PROPERTY, SoftDeleteHandlerV1.class.getName(), DeleteHandlerV1.class); DELETE_HANDLER_V1_IMPLEMENTATION_PROPERTY, SoftDeleteHandlerV1.class.getName(), DeleteHandlerV1.class);
} catch (AtlasException e) { } catch (AtlasException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment