bp:#44906
This commit is contained in:
@ -183,9 +183,7 @@ public class PaimonScanNode extends FileQueryScanNode {
|
||||
fileDesc.setDbId(((PaimonExternalTable) source.getTargetTable()).getDbId());
|
||||
fileDesc.setTblId(source.getTargetTable().getId());
|
||||
fileDesc.setLastUpdateTime(source.getTargetTable().getUpdateTime());
|
||||
fileDesc.setPaimonTable(encodeObjectToString(source.getPaimonTable()));
|
||||
// The hadoop conf should be same with
|
||||
// PaimonExternalCatalog.createCatalog()#getConfiguration()
|
||||
// The hadoop conf should be same with PaimonExternalCatalog.createCatalog()#getConfiguration()
|
||||
fileDesc.setHadoopConf(source.getCatalog().getCatalogProperty().getHadoopProperties());
|
||||
Optional<DeletionFile> optDeletionFile = paimonSplit.getDeletionFile();
|
||||
if (optDeletionFile.isPresent()) {
|
||||
|
||||
Reference in New Issue
Block a user