Repository: incubator-atlas Updated Branches: refs/heads/master 8cdc8981d -> 1a405f9c1
ATLAS-675 Storm Hook should use timetsamps as Date type 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/1a405f9c Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/1a405f9c Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/1a405f9c Branch: refs/heads/master Commit: 1a405f9c18f9570886ffb56f3bf008b2cc4adc0c Parents: 8cdc898 Author: Suma Shivaprasad <[email protected]> Authored: Thu Aug 18 08:24:07 2016 -0700 Committer: Suma Shivaprasad <[email protected]> Committed: Thu Aug 18 08:26:12 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/atlas/storm/hook/StormAtlasHook.java | 3 ++- .../main/scala/org/apache/atlas/storm/model/StormDataModel.scala | 4 ++-- release-log.txt | 3 ++- 3 files changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/1a405f9c/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java ---------------------------------------------------------------------- diff --git a/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java b/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java index 5ed4d99..89e1097 100644 --- a/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/1a405f9c/addons/storm-bridge/src/main/scala/org/apache/atlas/storm/model/StormDataModel.scala ---------------------------------------------------------------------- diff --git a/addons/storm-bridge/src/main/scala/org/apache/atlas/storm/model/StormDataModel.scala b/addons/storm-bridge/src/main/scala/org/apache/atlas/storm/model/StormDataModel.scala index 005f441..7caf5e8 100644 --- a/addons/storm-bridge/src/main/scala/org/apache/atlas/storm/model/StormDataModel.scala +++ b/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) http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/1a405f9c/release-log.txt ---------------------------------------------------------------------- diff --git a/release-log.txt b/release-log.txt index 7463713..e79caa6 100644 --- a/release-log.txt +++ b/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)
