fix: sort by time enable in follow (#5151)

This commit is contained in:
Huaijin
2024-11-26 16:47:14 +08:00
committed by GitHub
parent fc9565bf10
commit 2dc11a2fd0
2 changed files with 11 additions and 1 deletions
@@ -311,7 +311,9 @@ impl TableProvider for NewListingTable {
)
}
},
None => {} // no ordering required
None => {
log::debug!("don't not set split_file_groups_by_statistics");
} // no ordering required
};
// extract types of partition columns
+8
View File
@@ -100,6 +100,14 @@ pub async fn search(
.downcast_ref::<NewEmptyExec>()
.unwrap();
// because when init ctx we don't know this information
if empty_exec.sorted_by_time() {
ctx.state_ref().write().config_mut().options_mut().set(
"datafusion.execution.split_file_groups_by_statistics",
"true",
)?;
}
// get stream name
let stream_name = empty_exec.name();