ATLAS-675 Storm Hook should use timetsamps as Date type instead of Long (ayubkhan via sumasai)

addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java

@@ -45,6 +45,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.Date;
 
 /**
  * StormAtlasHook sends storm topology metadata information to Atlas
@@ -117,7 +118,7 @@ public class StormAtlasHook extends AtlasHook implements ISubmitterHook {
             owner = ANONYMOUS_OWNER;
         }
         topologyReferenceable.set(AtlasClient.OWNER, owner);
-        topologyReferenceable.set("startTime", System.currentTimeMillis());
+        topologyReferenceable.set("startTime", new Date(System.currentTimeMillis()));
         topologyReferenceable.set(AtlasConstants.CLUSTER_NAME_ATTRIBUTE, getClusterName(stormConf));
 
         return topologyReferenceable;

addons/storm-bridge/src/main/scala/org/apache/atlas/storm/model/StormDataModel.scala

@@ -45,8 +45,8 @@ object StormDataModel extends App {
          */
         _class(StormDataTypes.STORM_TOPOLOGY.getName, List(AtlasClient.PROCESS_SUPER_TYPE)) {
             "id" ~ (string, required, indexed, unique)
-            "startTime" ~ long
-            "endTime" ~ long
+            "startTime" ~ date
+            "endTime" ~ date
             "conf" ~ (map(string, string), optional)
             "clusterName" ~ (string, optional, indexed)
 

release-log.txt

@@ -3,11 +3,12 @@ Apache Atlas Release Notes
 
 --trunk - unreleased
 INCOMPATIBLE CHANGES:
+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)
 
 ALL CHANGES:
 ATLAS-1125 Enable compression on hbase audit table (shwethags via sumasai)
-ATLAS-1122 Change trait edge labels to have trait name alone (sumasai)
 ATLAS-1121 NPE while submitting topology in StormHook (ayubkhan via sumasai)
 ATLAS-1119 Add retries for edge label creation (sumasai via shwethags)
 ATLAS-1111 Data loss is observed when atlas is restarted while hive_table metadata ingestion into kafka topic is in-progress(shwethags via sumasai)