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:26:27 UTC
incubator-atlas git commit: ATLAS-675 Storm Hook should use
timetsamps as Date type instead of Long (ayubkhan via sumasai)
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 <su...@gmail.com>
Authored: Thu Aug 18 08:24:07 2016 -0700
Committer: Suma Shivaprasad <su...@gmail.com>
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)