From 5de04df61a752bff395f67c7a206e55a1ada5ad6 Mon Sep 17 00:00:00 2001 From: Gwen Shapira Date: Sat, 28 Feb 2015 22:31:25 -0800 Subject: [PATCH] SQOOP-2150: Sqoop2: Kite 1.0 don't allow dashes to be used in dataset names (Jarek Jarcec Cecho via Gwen Shapira) --- .../org/apache/sqoop/connector/kite/KiteDatasetExecutor.java | 2 +- .../main/java/org/apache/sqoop/connector/kite/KiteLoader.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) 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 cf8b627b..8a7bda49 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 @@ -159,7 +159,7 @@ public void mergeDataset(String uri) { */ public static String suggestTemporaryDatasetUri(String uri) { if (uri.startsWith("dataset:hdfs:")) { - return uri + TEMPORARY_DATASET_PREFIX + UUID.randomUUID(); + return uri + TEMPORARY_DATASET_PREFIX + UUID.randomUUID().toString().replace("-", ""); } else { throw new SqoopException( KiteConnectorError.GENERIC_KITE_CONNECTOR_0000, uri); diff --git a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteLoader.java b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteLoader.java index 1710969c..57790a14 100644 --- a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteLoader.java +++ b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteLoader.java @@ -48,6 +48,7 @@ KiteDatasetExecutor getExecutor(String uri, Schema schema, // not able to pass the temporary dataset uri to KiteToDestroyer. So we // delegate KiteDatasetExecutor to manage name convention for datasets. uri = KiteDatasetExecutor.suggestTemporaryDatasetUri(uri); + LOG.info("Generated temporary dataset URI: " + uri); Dataset dataset = KiteDatasetExecutor.createDataset(uri, schema, format); return new KiteDatasetExecutor(dataset);