Repository: atlas
Updated Branches:
  refs/heads/master 5618ad4ce -> a69496427


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


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

Branch: refs/heads/master
Commit: a69496427df2da9f66392b115b8a938fe26f4bf1
Parents: 5618ad4
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:16:47 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/a6949642/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 4ca3280..06a0e9c 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