[core][bug]Fix partition table get index RowType error

apache · Aug 5, 2024 · fa40316 · fa40316
1 parent d0e0c76
commit fa40316
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/...on-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java b/...on-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java
@@ -174,23 +174,23 @@ public void testLargeRecords() {
     @Test
     public void testBootstrapType() throws Exception {
         Catalog catalog = CatalogFactory.createCatalog(CatalogContext.create(new Path(path)));
-        FileStoreTable T = (FileStoreTable) catalog.getTable(Identifier.create("default", "T"));
-        FileStoreTable partial_update_t =
+        FileStoreTable t = (FileStoreTable) catalog.getTable(Identifier.create("default", "T"));
+        FileStoreTable partialUpdateT =
                 (FileStoreTable) catalog.getTable(Identifier.create("default", "partial_update_t"));
-        FileStoreTable first_row_t =
+        FileStoreTable firstRowT =
                 (FileStoreTable) catalog.getTable(Identifier.create("default", "first_row_t"));
-        assertThat(IndexBootstrap.bootstrapType(T.schema()).getFieldNames()).contains(BUCKET_FIELD);
-        assertThat(IndexBootstrap.bootstrapType(partial_update_t.schema()).getFieldNames())
+        assertThat(IndexBootstrap.bootstrapType(t.schema()).getFieldNames()).contains(BUCKET_FIELD);
+        assertThat(IndexBootstrap.bootstrapType(partialUpdateT.schema()).getFieldNames())
                 .contains(BUCKET_FIELD);
-        assertThat(IndexBootstrap.bootstrapType(first_row_t.schema()).getFieldNames())
+        assertThat(IndexBootstrap.bootstrapType(firstRowT.schema()).getFieldNames())
                 .contains(BUCKET_FIELD);
-        assertThat(IndexBootstrap.bootstrapType(T.schema()).getFieldIndex(BUCKET_FIELD))
+        assertThat(IndexBootstrap.bootstrapType(t.schema()).getFieldIndex(BUCKET_FIELD))
                 .isEqualTo(2);
         assertThat(
-                        IndexBootstrap.bootstrapType(partial_update_t.schema())
+                        IndexBootstrap.bootstrapType(partialUpdateT.schema())
                                 .getFieldIndex(BUCKET_FIELD))
                 .isEqualTo(2);
-        assertThat(IndexBootstrap.bootstrapType(first_row_t.schema()).getFieldIndex(BUCKET_FIELD))
+        assertThat(IndexBootstrap.bootstrapType(firstRowT.schema()).getFieldIndex(BUCKET_FIELD))
                 .isEqualTo(2);
     }
 }