From 498bbdb8b856dcab7aa59874e9035155531fe288 Mon Sep 17 00:00:00 2001
From: KaimingChen <kai_ming_chen@163.com>
Date: Mon, 22 Aug 2016 23:16:21 +0800
Subject: [PATCH] sqoop merge tool composite merge-key

---
 src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java b/src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java
index 378a12e0..1bb8deef 100644
--- a/src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java
+++ b/src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java
@@ -76,9 +76,10 @@ protected void processRecord(SqoopRecord r, Context c)
     }
     Object keyObj = null;
     if (keyColName.contains(",")) {
+        String connectStr = new String(new byte[]{1});
         StringBuilder keyFieldsSb = new StringBuilder();
         for (String str : keyColName.split(",")) {
-            keyFieldsSb.append("+").append(fieldMap.get(str).toString());
+            keyFieldsSb.append(connectStr).append(fieldMap.get(str).toString());
         }
         keyObj = keyFieldsSb;
     } else {