atlas-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mad...@apache.org
Subject [23/50] [abbrv] incubator-atlas git commit: ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)
Date Fri, 23 Dec 2016 01:46:52 GMT
ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)

(cherry picked from commit 7b7f4e0b68637fec82af4443aedcecc63cf10747)


Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/d82224d9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/d82224d9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/d82224d9

Branch: refs/heads/0.7-incubating
Commit: d82224d9a494880fe09659597fd8c78f4bc32d5f
Parents: 1eb2c87
Author: Suma Shivaprasad <sumasai.shivaprasad@gmail.com>
Authored: Thu Aug 18 08:35:43 2016 -0700
Committer: Madhan Neethiraj <madhan@apache.org>
Committed: Thu Dec 22 15:22:09 2016 -0800

----------------------------------------------------------------------
 .../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/d82224d9/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/d82224d9/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/d82224d9/release-log.txt
----------------------------------------------------------------------
diff --git a/release-log.txt b/release-log.txt
index 9879a01..64a8a3e 100644
--- a/release-log.txt
+++ b/release-log.txt
@@ -3,6 +3,7 @@ Apache Atlas Release Notes
 
 --Release 0.7-incubating
 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)


Mime
View raw message