Repository: incubator-tephra Updated Branches: refs/heads/feature/fix-balancebooks [created] c2a2ea8ba
Ignore TableExistsException in BalanceBooks Project: http://git-wip-us.apache.org/repos/asf/incubator-tephra/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-tephra/commit/c2a2ea8b Tree: http://git-wip-us.apache.org/repos/asf/incubator-tephra/tree/c2a2ea8b Diff: http://git-wip-us.apache.org/repos/asf/incubator-tephra/diff/c2a2ea8b Branch: refs/heads/feature/fix-balancebooks Commit: c2a2ea8ba29c2e075f667d75d9cb2ffe8128680c Parents: 42828c7 Author: Gokul Gunasekaran <[email protected]> Authored: Mon May 16 15:15:29 2016 -0700 Committer: Gokul Gunasekaran <[email protected]> Committed: Mon May 16 15:15:29 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/tephra/examples/BalanceBooks.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/c2a2ea8b/tephra-examples/src/main/java/org/apache/tephra/examples/BalanceBooks.java ---------------------------------------------------------------------- diff --git a/tephra-examples/src/main/java/org/apache/tephra/examples/BalanceBooks.java b/tephra-examples/src/main/java/org/apache/tephra/examples/BalanceBooks.java index b2fbf14..d44244f 100644 --- a/tephra-examples/src/main/java/org/apache/tephra/examples/BalanceBooks.java +++ b/tephra-examples/src/main/java/org/apache/tephra/examples/BalanceBooks.java @@ -24,6 +24,7 @@ import com.google.inject.Injector; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; +import org.apache.hadoop.hbase.TableExistsException; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; @@ -202,7 +203,11 @@ public class BalanceBooks implements Closeable { desc.addFamily(columnDesc); } desc.addCoprocessor(TransactionProcessor.class.getName()); - admin.createTable(desc); + try { + admin.createTable(desc); + } catch (TableExistsException ex) { + LOG.debug("Table {} exists already : {}", tableName, ex); + } } }
