Skip to content

Commit ab92bc7

Browse files
macdoormacdoor
committed
升级 paimon 1.3.0
1 parent cd9df36 commit ab92bc7

File tree

4 files changed

+25
-25
lines changed

4 files changed

+25
-25
lines changed

‎fe/fe-core/src/main/java/com/starrocks/connector/paimon/PaimonMetadata.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ private void updatePartitionInfo(String databaseName, String tableName) {
172172
}
173173

174174
private boolean getPartitionLegacyName(org.apache.paimon.table.Table paimonTable) {
175-
String partitionLegacyName = paimonTable.options().get(CoreOptions.PARTITION_GENERATE_LEGCY_NAME.key());
175+
String partitionLegacyName = paimonTable.options().get(CoreOptions.PARTITION_GENERATE_LEGACY_NAME.key());
176176
//If the user does not explicitly set this option, the result is null,but its default value is true.
177177
return StringUtils.isEmpty(partitionLegacyName) || Boolean.parseBoolean(partitionLegacyName);
178178
}

‎fe/fe-core/src/test/java/com/starrocks/connector/paimon/PaimonMetadataTest.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -157,14 +157,14 @@ public void setUp() {
157157
writer.writeInt(1, 5555);
158158
writer.complete();
159159
List<DataFileMeta> meta1 = new ArrayList<>();
160-
meta1.add(new DataFileMeta("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
161-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
162-
meta1.add(new DataFileMeta("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
163-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
160+
meta1.add(DataFileMeta.create("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
161+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
162+
meta1.add(DataFileMeta.create("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
163+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
164164

165165
List<DataFileMeta> meta2 = new ArrayList<>();
166-
meta2.add(new DataFileMeta("file3", 100, 400, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
167-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
166+
meta2.add(DataFileMeta.create("file3", 100, 400, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
167+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
168168
this.splits.add(DataSplit.builder().withSnapshot(1L).withPartition(row1).withBucket(1)
169169
.withBucketPath("not used").withDataFiles(meta1).isStreaming(false).build());
170170
this.splits.add(DataSplit.builder().withSnapshot(1L).withPartition(row2).withBucket(1)

‎fe/fe-core/src/test/java/com/starrocks/planner/PaimonScanNodeTest.java‎

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -78,10 +78,10 @@ public void testTotalFileLength(@Mocked PaimonTable table) {
7878
writer.complete();
7979

8080
List<DataFileMeta> meta1 = new ArrayList<>();
81-
meta1.add(new DataFileMeta("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
82-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
83-
meta1.add(new DataFileMeta("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
84-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
81+
meta1.add(DataFileMeta.create("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
82+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
83+
meta1.add(DataFileMeta.create("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
84+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
8585

8686
DataSplit split = DataSplit.builder().withSnapshot(1L).withPartition(row1).withBucket(1)
8787
.withBucketPath("not used").withDataFiles(meta1).isStreaming(false).build();
@@ -103,10 +103,10 @@ public void testEstimatedLength(@Mocked PaimonTable table) {
103103
writer.complete();
104104

105105
List<DataFileMeta> meta1 = new ArrayList<>();
106-
meta1.add(new DataFileMeta("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
107-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
108-
meta1.add(new DataFileMeta("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
109-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
106+
meta1.add(DataFileMeta.create("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
107+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
108+
meta1.add(DataFileMeta.create("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
109+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
110110

111111
DataSplit split = DataSplit.builder().withSnapshot(1L).withPartition(row1).withBucket(1)
112112
.withBucketPath("not used").withDataFiles(meta1).isStreaming(false).build();
@@ -134,10 +134,10 @@ public void testSplitRawFileScanRange(@Mocked PaimonTable table, @Mocked RawFile
134134

135135
List<DataFileMeta> meta1 = new ArrayList<>();
136136

137-
meta1.add(new DataFileMeta("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
138-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
139-
meta1.add(new DataFileMeta("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
140-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
137+
meta1.add(DataFileMeta.create("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
138+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
139+
meta1.add(DataFileMeta.create("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
140+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
141141

142142
DataSplit split = DataSplit.builder().withSnapshot(1L).withPartition(row1).withBucket(1)
143143
.withBucketPath("not used").withDataFiles(meta1).isStreaming(false).build();
@@ -167,10 +167,10 @@ public void testAddSplitScanRangeLocations(@Mocked PaimonTable table, @Mocked Ra
167167

168168
List<DataFileMeta> meta1 = new ArrayList<>();
169169

170-
meta1.add(new DataFileMeta("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
171-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
172-
meta1.add(new DataFileMeta("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
173-
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null));
170+
meta1.add(DataFileMeta.create("file1", 100, 200, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
171+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
172+
meta1.add(DataFileMeta.create("file2", 100, 300, EMPTY_MIN_KEY, EMPTY_MAX_KEY, EMPTY_STATS, EMPTY_STATS,
173+
1, 1, 1, DUMMY_LEVEL, 0L, null, null, null, null, null));
174174

175175
DataSplit split = DataSplit.builder().withSnapshot(1L).withPartition(row1).withBucket(1)
176176
.withBucketPath("not used").withDataFiles(meta1).isStreaming(false).build();
@@ -182,4 +182,4 @@ public void testAddSplitScanRangeLocations(@Mocked PaimonTable table, @Mocked Ra
182182
TScanRangeLocations tScanRangeLocations = scanNode.getScanRangeLocations(10).get(0);
183183
Assertions.assertEquals(THdfsFileFormat.UNKNOWN, tScanRangeLocations.getScan_range().getHdfs_scan_range().getFile_format());
184184
}
185-
}
185+
}

‎fe/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ under the License.
6969
<dnsjava.version>3.6.3</dnsjava.version>
7070
<nimbusds.version>9.37.2</nimbusds.version>
7171
<protobuf-java.version>3.25.5</protobuf-java.version>
72-
<paimon.version>1.2.0</paimon.version>
72+
<paimon.version>1.3.0</paimon.version>
7373
<delta-kernel.version>4.0.0rc1</delta-kernel.version>
7474
<iceberg.version>1.10.0</iceberg.version>
7575
<staros.version>4.0.0</staros.version>

0 commit comments

Comments
 (0)