@Test
  public void testCreateTableWithMultiIdentifierFields() {
    TableIdentifier identifier = TableIdentifier.of("default", "customers");
    String query = String.format("CREATE EXTERNAL TABLE customers (" +
                    "customer_id BIGINT," +
                    "first_name STRING, " +
                    "last_name STRING," +
                    "primary key (customer_id, first_name) disable novalidate) " +
                    "STORED BY iceBerg %s TBLPROPERTIES ('%s'='%s')",
            testTables.locationForCreateTableSQL(identifier),
            InputFormatConfig.CATALOG_NAME,
            testTables.catalogName());
    shell.executeStatement(query);
    org.apache.iceberg.Table table = testTables.loadTable(identifier);
    Assert.assertEquals("Should have new two identifier fields",
            Sets.newHashSet(table.schema().findField("customer_id").fieldId(),
                    table.schema().findField("first_name").fieldId()), table.schema().identifierFieldIds());
  }
Checks that the new schema has newintcol and newstring col columns on both HMS and Iceberg sides
@throws Exception - any test error
iceberg/iceberg-handler/src/test/java/org/apache/iceberg/mr/hive/TestHiveIcebergStorageHandlerNoScan.java