You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by su...@apache.org on 2016/08/18 15:36:08 UTC
incubator-atlas git commit: ATLAS-674 Falcon Hook should use
timestamps instead of long(ayubkhan via sumasai)
Repository: incubator-atlas
Updated Branches:
refs/heads/master 1a405f9c1 -> 7b7f4e0b6
ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)
Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/7b7f4e0b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/7b7f4e0b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/7b7f4e0b
Branch: refs/heads/master
Commit: 7b7f4e0b68637fec82af4443aedcecc63cf10747
Parents: 1a405f9
Author: Suma Shivaprasad <su...@gmail.com>
Authored: Thu Aug 18 08:35:43 2016 -0700
Committer: Suma Shivaprasad <su...@gmail.com>
Committed: Thu Aug 18 08:35:43 2016 -0700
----------------------------------------------------------------------
.../main/java/org/apache/atlas/falcon/event/FalconEvent.java | 8 +-------
.../java/org/apache/atlas/falcon/service/AtlasService.java | 3 ++-
release-log.txt | 1 +
3 files changed, 4 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
----------------------------------------------------------------------
diff --git a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
index e6203ed..0b918ba 100644
--- a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
+++ b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
@@ -28,13 +28,11 @@ import java.util.Date;
public class FalconEvent {
protected String user;
protected OPERATION operation;
- protected long timestamp;
protected Entity entity;
- public FalconEvent(String doAsUser, OPERATION falconOperation, long timestamp, Entity entity) {
+ public FalconEvent(String doAsUser, OPERATION falconOperation, Entity entity) {
this.user = doAsUser;
this.operation = falconOperation;
- this.timestamp = timestamp;
this.entity = entity;
}
@@ -55,10 +53,6 @@ public class FalconEvent {
return operation;
}
- public Date getTimestamp() {
- return new Date(timestamp);
- }
-
public Entity getEntity() {
return entity;
}
http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/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 b2afb03..7482ba7 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
@@ -30,6 +30,7 @@ import org.apache.falcon.service.FalconService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
/**
* Atlas service to publish Falcon events
*/
@@ -124,7 +125,7 @@ public class AtlasService implements FalconService, ConfigurationChangeListener
try {
FalconEvent event =
- new FalconEvent(EventUtil.getUser(), operation, System.currentTimeMillis(), entity);
+ new FalconEvent(EventUtil.getUser(), operation, entity);
FalconEventPublisher.Data data = new FalconEventPublisher.Data(event);
publisher.publish(data);
} catch (Exception ex) {
http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/release-log.txt
----------------------------------------------------------------------
diff --git a/release-log.txt b/release-log.txt
index e79caa6..31582ed 100644
--- a/release-log.txt
+++ b/release-log.txt
@@ -3,6 +3,7 @@ Apache Atlas Release Notes
--trunk - unreleased
INCOMPATIBLE CHANGES:
+ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)
ATLAS-675 Storm Hook should use timetsamps as Date type instead of Long (ayubkhan via sumasai)
ATLAS-1122 Change trait edge labels to have trait name alone (sumasai)
ATLAS-1060 Add composite indexes for exact match performance improvements for all attributes (sumasai via shwethags)