Fix to prevent importing existing storage table

core/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdmin.java

@@ -209,7 +209,7 @@ public Set<String> getNamespaceNames() throws ExecutionException {
   @Override
   public void importTable(String namespace, String table, Map<String, String> options)
       throws ExecutionException {
-    TableMetadata tableMetadata = getTableMetadata(namespace, table);
+    TableMetadata tableMetadata = admin.getTableMetadata(namespace, table);
     if (tableMetadata != null) {
       throw new IllegalArgumentException(
           "Table already exists: " + ScalarDbUtils.getFullTableName(namespace, table));

core/src/test/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminTestBase.java

@@ -633,7 +633,29 @@ public void importTable_ShouldCallStorageAdminProperly() throws ExecutionExcepti
   }
 
   @Test
-  public void importTable_WithTableAlreadyExists_ShouldThrowIllegalArgumentException()
+  public void importTable_WithStorageTableAlreadyExists_ShouldThrowIllegalArgumentException()
+      throws ExecutionException {
+    // Arrange
+    String primaryKeyColumn = "pk";
+    String column = "col";
+    TableMetadata metadata =
+        TableMetadata.newBuilder()
+            .addColumn(primaryKeyColumn, DataType.INT)
+            .addColumn(column, DataType.INT)
+            .addPartitionKey(primaryKeyColumn)
+            .build();
+    when(distributedStorageAdmin.getTableMetadata(NAMESPACE, TABLE)).thenReturn(metadata);
+
+    // Act
+    Throwable thrown =
+        catchThrowable(() -> admin.importTable(NAMESPACE, TABLE, Collections.emptyMap()));
+
+    // Assert
+    assertThat(thrown).isInstanceOf(IllegalArgumentException.class);
+  }
+
+  @Test
+  public void importTable_WithTransactionTableAlreadyExists_ShouldThrowIllegalArgumentException()
       throws ExecutionException {
     // Arrange
     String primaryKeyColumn = "pk";