fix postcommits

Author: ahmedabu98

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/InMemoryMetaStore.java

@@ -99,7 +99,6 @@ protected void validateTableType(Table table) {
 
   @Override
   public void registerProvider(TableProvider provider) {
-    System.out.printf("xxx register provider!!! type: '%s'%n", provider.getTableType());
     if (providers.containsKey(provider.getTableType())) {
       throw new IllegalArgumentException(
           "Provider is already registered for table type: " + provider.getTableType());

sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/PubsubToIcebergIT.java

@@ -149,18 +149,15 @@ public void testSimpleInsertWithPartitionedFields() throws Exception {
             + "' \n"
             + "TBLPROPERTIES '{ \"timestampAttributeKey\" : \"ts\" }'";
     String icebergTableString =
-        "CREATE EXTERNAL TABLE iceberg_table( \n"
+        format("CREATE EXTERNAL TABLE %s( \n", tableIdentifier)
             + "   id BIGINT, \n"
             + "   name VARCHAR \n "
             + ") \n"
             + "TYPE 'iceberg' \n"
             + "PARTITIONED BY('id', 'truncate(name, 3)') \n"
-            + "LOCATION '"
-            + tableIdentifier
-            + "' \n"
             + "TBLPROPERTIES '{ \"triggering_frequency_seconds\" : 10 }'";
     String insertStatement =
-        "INSERT INTO iceberg_table \n"
+        format("INSERT INTO %s \n", tableIdentifier)
             + "SELECT \n"
             + "  pubsub_topic.payload.id, \n"
             + "  pubsub_topic.payload.name \n"
@@ -207,18 +204,15 @@ public void testSimpleInsertFlat() throws Exception {
             + pubsub.topicPath()
             + "' \n"
             + "TBLPROPERTIES '{ \"timestampAttributeKey\" : \"ts\" }'";
-    String bqTableString =
-        "CREATE EXTERNAL TABLE iceberg_table( \n"
+    String icebergTableString =
+        format("CREATE EXTERNAL TABLE %s( \n", tableIdentifier)
             + "   id BIGINT, \n"
             + "   name VARCHAR \n "
             + ") \n"
             + "TYPE 'iceberg' \n"
-            + "LOCATION '"
-            + tableIdentifier
-            + "' \n"
             + "TBLPROPERTIES '{ \"triggering_frequency_seconds\" : 10 }'";
     String insertStatement =
-        "INSERT INTO iceberg_table \n"
+        format("INSERT INTO %s \n", tableIdentifier)
             + "SELECT \n"
             + "  id, \n"
             + "  name \n"
@@ -229,7 +223,7 @@ public void testSimpleInsertFlat() throws Exception {
             .withDdlString(createCatalogDdl)
             .withDdlString(setCatalogDdl)
             .withDdlString(pubsubTableString)
-            .withDdlString(bqTableString));
+            .withDdlString(icebergTableString));
     pipeline.run();
 
     // Block until a subscription for this topic exists