Repository: atlas
Updated Branches:
  refs/heads/branch-0.8 e8908dbfe -> d0ac50a4a


ATLAS-2439: updated Sqoop hook to use V2 notifications (#2)

(cherry picked from commit a69496427df2da9f66392b115b8a938fe26f4bf1)


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

Branch: refs/heads/branch-0.8
Commit: d0ac50a4af17b4c44572aa84db7c80e9b4643574
Parents: e8908db
Author: Madhan Neethiraj <mad...@apache.org>
Authored: Tue Feb 13 23:16:47 2018 -0800
Committer: Madhan Neethiraj <mad...@apache.org>
Committed: Tue Feb 13 23:50:46 2018 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/atlas/blob/d0ac50a4/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java
----------------------------------------------------------------------
diff --git 
a/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java 
b/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java
index 5201122..9e43430 100644
--- 
a/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java
+++ 
b/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java
@@ -160,11 +160,11 @@ public class SqoopHook extends SqoopJobDataPublisher {
         entProcess.setAttribute(SqoopHook.OPERATION, data.getOperation());
 
         if (isImportOperation(data)) {
-            entProcess.setAttribute(SqoopHook.INPUTS, 
AtlasTypeUtil.getAtlasObjectId(entDbStore));
-            entProcess.setAttribute(SqoopHook.OUTPUTS, 
AtlasTypeUtil.getAtlasObjectId(entHiveTable));
+            entProcess.setAttribute(SqoopHook.INPUTS, 
Arrays.asList(AtlasTypeUtil.getAtlasObjectId(entDbStore)));
+            entProcess.setAttribute(SqoopHook.OUTPUTS, 
Arrays.asList(AtlasTypeUtil.getAtlasObjectId(entHiveTable)));
         } else {
-            entProcess.setAttribute(SqoopHook.INPUTS, 
AtlasTypeUtil.getAtlasObjectId(entHiveTable));
-            entProcess.setAttribute(SqoopHook.OUTPUTS, 
AtlasTypeUtil.getAtlasObjectId(entDbStore));
+            entProcess.setAttribute(SqoopHook.INPUTS, 
Arrays.asList(AtlasTypeUtil.getAtlasObjectId(entHiveTable)));
+            entProcess.setAttribute(SqoopHook.OUTPUTS, 
Arrays.asList(AtlasTypeUtil.getAtlasObjectId(entDbStore)));
         }
 
         entProcess.setAttribute(SqoopHook.USER, data.getUser());

Reply via email to