You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by sh...@apache.org on 2016/07/29 09:11:40 UTC
incubator-atlas git commit: ATLAS-1066 Falcon fails to post entity to
Atlas due to kafka exception (mneethiraj via shwethags)
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 <ss...@hortonworks.com>
Authored: Fri Jul 29 14:41:34 2016 +0530
Committer: Shwetha GS <ss...@hortonworks.com>
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)