You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by ma...@apache.org on 2018/02/14 07:49:43 UTC
atlas git commit: ATLAS-2439: updated Sqoop hook to use V2
notifications (#2)
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 <ma...@apache.org>
Authored: Tue Feb 13 23:16:47 2018 -0800
Committer: Madhan Neethiraj <ma...@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());