fix ut

apache · Mar 8, 2024 · 7d40cda · 7d40cda
1 parent 17825e6
commit 7d40cda
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java b/paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java
@@ -140,15 +140,15 @@ public RecordReader<InternalRow> createReader(DataSplit split) throws IOExceptio
 
                                 Pair<int[], RowType> partitionPair = null;
                                 if (!dataSchema.partitionKeys().isEmpty()) {
-                                    Pair<int[], int[][]> partitionMappping =
+                                    Pair<int[], int[][]> partitionMapping =
                                             PartitionUtils.constructPartitionMapping(
                                                     dataSchema, dataProjection);
                                     // if partition fields are not selected, we just do nothing
-                                    if (partitionMappping != null) {
-                                        dataProjection = partitionMappping.getRight();
+                                    if (partitionMapping != null) {
+                                        dataProjection = partitionMapping.getRight();
                                         partitionPair =
                                                 Pair.of(
-                                                        partitionMappping.getLeft(),
+                                                        partitionMapping.getLeft(),
                                                         dataSchema.projectedLogicalRowType(
                                                                 dataSchema.partitionKeys()));
                                     }

diff --git a/...mon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java b/...mon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
@@ -277,7 +277,7 @@ public void testCreateExternalTable() throws Exception {
                 .isTrue();
         tEnv.executeSql("DROP TABLE t").await();
         Path tablePath = new Path(path, "test_db.db/t");
-        assertThat(tablePath.getFileSystem().exists(tablePath)).isFalse();
+        assertThat(tablePath.getFileSystem().exists(tablePath)).isTrue();
     }
 
     @Test