Skip to content

Commit 6a516d1

Browse files
committed
fix case
1 parent 10a8901 commit 6a516d1

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

be/test/vec/exec/format/paimon/paimon_schema_change_test.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ class PaimonReaderTest : public ::testing::Test {
6767
_state = new RuntimeState(TQueryGlobals());
6868
_io_ctx = new io::IOContext();
6969
_kv_cache = new ShardedKVCache(10);
70-
_schema_file_path = ".be/test/exec/test_data/paimon_scanner/schema-0";
70+
_schema_file_path = "./be/test/exec/test_data/paimon_scanner/schema-0";
7171
}
7272

7373
void TearDown() override {

fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/source/PaimonScanNode.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -175,8 +175,9 @@ private void setPaimonParams(TFileRangeDesc rangeDesc, PaimonSplit paimonSplit)
175175
throw new RuntimeException("Unsupported file format: " + fileFormat);
176176
}
177177
}
178-
179-
fileDesc.setSchemaFilePath(paimonSplit.getSchemaFilePath());
178+
LocationPath schemaPath = new LocationPath(paimonSplit.getSchemaFilePath(),
179+
source.getCatalog().getProperties());
180+
fileDesc.setSchemaFilePath(schemaPath.toStorageLocation().toString());
180181
fileDesc.setFileFormat(fileFormat);
181182
fileDesc.setPaimonPredicate(encodeObjectToString(predicates));
182183
fileDesc.setPaimonColumnNames(source.getDesc().getSlots().stream().map(slot -> slot.getColumn().getName())

0 commit comments

Comments
 (0)