You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2015/03/07 16:57:53 UTC
sqoop git commit: SQOOP-2188: Sqoop2: Failed to merge Kite datasets
Repository: sqoop
Updated Branches:
refs/heads/sqoop2 dedd84a4a -> ddb82e965
SQOOP-2188: Sqoop2: Failed to merge Kite datasets
(Qian Xu via Jarek Jarcec Cecho)
Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/ddb82e96
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/ddb82e96
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/ddb82e96
Branch: refs/heads/sqoop2
Commit: ddb82e965e3db5e2f7aeb7db0a0e79bf67536135
Parents: dedd84a
Author: Jarek Jarcec Cecho <ja...@apache.org>
Authored: Sat Mar 7 07:57:22 2015 -0800
Committer: Jarek Jarcec Cecho <ja...@apache.org>
Committed: Sat Mar 7 07:57:22 2015 -0800
----------------------------------------------------------------------
.../org/apache/sqoop/connector/kite/KiteDatasetExecutor.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/sqoop/blob/ddb82e96/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteDatasetExecutor.java
----------------------------------------------------------------------
diff --git a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteDatasetExecutor.java b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteDatasetExecutor.java
index 4381717..b111b5c 100644
--- a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteDatasetExecutor.java
+++ b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteDatasetExecutor.java
@@ -36,8 +36,8 @@ import org.kitesdk.data.URIBuilder;
import org.kitesdk.data.spi.filesystem.FileSystemDataset;
import java.net.URI;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.HashSet;
+import java.util.Set;
import java.util.UUID;
/**
@@ -175,7 +175,7 @@ public class KiteDatasetExecutor {
public static String[] listTemporaryDatasetUris(String uri) {
String repo = URIBuilder.REPO_SCHEME +
uri.substring(URIBuilder.DATASET_SCHEME.length());
- List<String> result = new ArrayList<String>();
+ Set<String> result = new HashSet<String>();
for (URI match : Datasets.list(repo)) {
if (match.toString().contains(TEMPORARY_DATASET_PREFIX)) {
result.add(match.toString());