Skip to content

Commit 6e20f60

Browse files
authored
Fix mod (#19855)
1 parent 300ce32 commit 6e20f60

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

plugins/engine-datafusion/jni/src/lib.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ use std::sync::Arc;
1717
mod util;
1818
mod row_id_optimizer;
1919
mod listing_table;
20-
mod memory;
2120

2221
use datafusion::execution::context::SessionContext;
2322

server/src/main/java/org/opensearch/index/engine/exec/coord/CompositeEngine.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,9 @@ public CompositeEngine(MapperService mapperService, PluginsService pluginsServic
7373
this.catalogSnapshot = ((LuceneCommitEngine)this.compositeEngineCommitter).readCatalogSnapshot();
7474

7575
// remap the paths
76-
this.catalogSnapshot = this.catalogSnapshot.remapPaths(shardPath.getDataPath());
76+
if(this.catalogSnapshot != null) {
77+
this.catalogSnapshot = this.catalogSnapshot.remapPaths(shardPath.getDataPath());
78+
}
7779

7880
this.mergeHandler = new ParquetMergeHandler(this, this.engine, this.engine.getDataFormat());
7981
mergeScheduler = new MergeScheduler(this.mergeHandler, this);

0 commit comments

Comments
 (0)