You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by am...@apache.org on 2014/11/13 12:49:40 UTC
[13/50] incubator-lens git commit: Ignore exception if example table
already created
Ignore exception if example table already created
Project: http://git-wip-us.apache.org/repos/asf/incubator-lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-lens/commit/31d41d91
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/31d41d91
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/31d41d91
Branch: refs/heads/toapache
Commit: 31d41d91902cf0124c7d9dbbac3dc9316f464193
Parents: a97d0d0
Author: jdhok <ja...@inmobi.com>
Authored: Fri Nov 7 14:02:47 2014 +0530
Committer: jdhok <ja...@inmobi.com>
Committed: Fri Nov 7 14:02:47 2014 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/lens/ml/ExampleUtils.java | 2 +-
.../src/test/java/org/apache/lens/ml/TestMLResource.java | 9 +++++++--
2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/31d41d91/lens-ml-lib/src/main/java/org/apache/lens/ml/ExampleUtils.java
----------------------------------------------------------------------
diff --git a/lens-ml-lib/src/main/java/org/apache/lens/ml/ExampleUtils.java b/lens-ml-lib/src/main/java/org/apache/lens/ml/ExampleUtils.java
index a48dcc2..8ca2b7a 100644
--- a/lens-ml-lib/src/main/java/org/apache/lens/ml/ExampleUtils.java
+++ b/lens-ml-lib/src/main/java/org/apache/lens/ml/ExampleUtils.java
@@ -92,7 +92,7 @@ public class ExampleUtils {
partCols.add(new FieldSchema("dummy_partition_col", "string", ""));
tbl.setPartCols(partCols);
- Hive.get(conf).createTable(tbl);
+ Hive.get(conf).createTable(tbl, false);
LOG.info("Created table " + tableName);
// Add partition for the data file
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/31d41d91/lens-ml-lib/src/test/java/org/apache/lens/ml/TestMLResource.java
----------------------------------------------------------------------
diff --git a/lens-ml-lib/src/test/java/org/apache/lens/ml/TestMLResource.java b/lens-ml-lib/src/test/java/org/apache/lens/ml/TestMLResource.java
index 4abc010..8ebff9c 100644
--- a/lens-ml-lib/src/test/java/org/apache/lens/ml/TestMLResource.java
+++ b/lens-ml-lib/src/test/java/org/apache/lens/ml/TestMLResource.java
@@ -30,6 +30,7 @@ import javax.ws.rs.core.Application;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hive.conf.HiveConf;
+import org.apache.hadoop.hive.ql.metadata.HiveException;
import org.apache.hive.service.Service;
import org.apache.lens.api.LensSessionHandle;
import org.apache.lens.client.LensConnectionParams;
@@ -180,8 +181,12 @@ public class TestMLResource extends LensJerseyTest {
LOG.info("Creating training table from file " + sampleDataFileURI.toString());
Map<String, String> tableParams = new HashMap<String, String>();
- ExampleUtils.createTable(conf, database, tableName, sampleDataFileURI.toString(), labelColumn, tableParams,
- features);
+ try {
+ ExampleUtils.createTable(conf, database, tableName, sampleDataFileURI.toString(), labelColumn, tableParams,
+ features);
+ } catch (HiveException exc) {
+ exc.printStackTrace();
+ }
MLTask.Builder taskBuilder = new MLTask.Builder();
taskBuilder.algorithm(algoName).hiveConf(conf).labelColumn(labelColumn).outputTable(outputTable)