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 <[email protected]> Authored: Sat Mar 7 07:57:22 2015 -0800 Committer: Jarek Jarcec Cecho <[email protected]> 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());
