Repository: incubator-atlas Updated Branches: refs/heads/master 05277c27d -> 2b14ec102
ATLAS-1066 Falcon fails to post entity to Atlas due to kafka exception (mneethiraj via shwethags) Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/2b14ec10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/2b14ec10 Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/2b14ec10 Branch: refs/heads/master Commit: 2b14ec1022f442576c996a5ec20e9a2a3803f011 Parents: 05277c2 Author: Shwetha GS <[email protected]> Authored: Fri Jul 29 14:41:34 2016 +0530 Committer: Shwetha GS <[email protected]> Committed: Fri Jul 29 14:41:34 2016 +0530 ---------------------------------------------------------------------- .../java/org/apache/atlas/falcon/service/AtlasService.java | 7 +++++++ .../main/java/org/apache/atlas/falcon/hook/FalconHook.java | 2 +- .../java/org/apache/atlas/falcon/service/AtlasService.java | 3 --- release-log.txt | 1 + 4 files changed, 9 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/2b14ec10/addons/falcon-bridge-shim/src/main/java/org/apache/atlas/falcon/service/AtlasService.java ---------------------------------------------------------------------- diff --git a/addons/falcon-bridge-shim/src/main/java/org/apache/atlas/falcon/service/AtlasService.java b/addons/falcon-bridge-shim/src/main/java/org/apache/atlas/falcon/service/AtlasService.java index a5dd400..6b4486a 100755 --- a/addons/falcon-bridge-shim/src/main/java/org/apache/atlas/falcon/service/AtlasService.java +++ b/addons/falcon-bridge-shim/src/main/java/org/apache/atlas/falcon/service/AtlasService.java @@ -21,6 +21,7 @@ package org.apache.atlas.falcon.service; import org.apache.atlas.plugin.classloader.AtlasPluginClassLoader; import org.apache.falcon.FalconException; +import org.apache.falcon.entity.store.ConfigurationStore; import org.apache.falcon.entity.v0.Entity; import org.apache.falcon.service.ConfigurationChangeListener; import org.apache.falcon.service.FalconService; @@ -74,6 +75,9 @@ public class AtlasService implements FalconService, ConfigurationChangeListener try { activatePluginClassLoader(); + + ConfigurationStore.get().registerListener(this); + falconServiceImpl.init(); } finally { deactivatePluginClassLoader(); @@ -92,6 +96,9 @@ public class AtlasService implements FalconService, ConfigurationChangeListener try { activatePluginClassLoader(); + + ConfigurationStore.get().unregisterListener(this); + falconServiceImpl.destroy(); } finally { deactivatePluginClassLoader(); http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/2b14ec10/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java ---------------------------------------------------------------------- diff --git a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java index 0acd964..d724f57 100644 --- a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java +++ b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java @@ -136,7 +136,7 @@ public class FalconHook extends AtlasHook implements FalconEventPublisher { }); } } catch (Throwable t) { - LOG.warn("Error in processing data {}", data); + LOG.warn("Error in processing data " + data, t); } } http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/2b14ec10/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java ---------------------------------------------------------------------- diff --git a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java index 889317e..b2afb03 100644 --- a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java +++ b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java @@ -23,7 +23,6 @@ import org.apache.atlas.falcon.event.FalconEvent; import org.apache.atlas.falcon.hook.FalconHook; import org.apache.atlas.falcon.publisher.FalconEventPublisher; import org.apache.falcon.FalconException; -import org.apache.falcon.entity.store.ConfigurationStore; import org.apache.falcon.entity.v0.Entity; import org.apache.falcon.entity.v0.EntityType; import org.apache.falcon.service.ConfigurationChangeListener; @@ -51,13 +50,11 @@ public class AtlasService implements FalconService, ConfigurationChangeListener @Override public void init() throws FalconException { - ConfigurationStore.get().registerListener(this); publisher = new FalconHook(); } @Override public void destroy() throws FalconException { - ConfigurationStore.get().unregisterListener(this); } @Override http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/2b14ec10/release-log.txt ---------------------------------------------------------------------- diff --git a/release-log.txt b/release-log.txt index 5b22771..3e7cc2a 100644 --- a/release-log.txt +++ b/release-log.txt @@ -6,6 +6,7 @@ INCOMPATIBLE CHANGES: ALL CHANGES: +ATLAS-1066 Falcon fails to post entity to Atlas due to kafka exception (mneethiraj via shwethags) ATLAS-1064 UI: Pagination for full text search results (Kalyanikashikar via shwethags) ATLAS-1006 Paginate full text search results (shwethags) ATLAS-1046 UI: Search pagination refinements (Kalyanikashikar via sumasai)
