diff --git a/datafusion/core/src/datasource/listing/table.rs b/datafusion/core/src/datasource/listing/table.rs index 72c6e0d84c04..80f49e4eb8e6 100644 --- a/datafusion/core/src/datasource/listing/table.rs +++ b/datafusion/core/src/datasource/listing/table.rs @@ -743,7 +743,7 @@ impl TableProvider for ListingTable { filters: &[Expr], limit: Option, ) -> Result> { - // TODO remove downcast_ref from here? + // TODO (https://github.com/apache/datafusion/issues/11600) remove downcast_ref from here? let session_state = state.as_any().downcast_ref::().unwrap(); let (mut partitioned_file_lists, statistics) = self .list_files_for_scan(session_state, filters, limit) @@ -883,7 +883,7 @@ impl TableProvider for ListingTable { // Get the object store for the table path. let store = state.runtime_env().object_store(table_path)?; - // TODO remove downcast_ref from here? + // TODO (https://github.com/apache/datafusion/issues/11600) remove downcast_ref from here? let session_state = state.as_any().downcast_ref::().unwrap(); let file_list_stream = pruned_partition_list( session_state, diff --git a/datafusion/core/src/datasource/listing_table_factory.rs b/datafusion/core/src/datasource/listing_table_factory.rs index ce52dd98166e..591a19aab49b 100644 --- a/datafusion/core/src/datasource/listing_table_factory.rs +++ b/datafusion/core/src/datasource/listing_table_factory.rs @@ -52,7 +52,7 @@ impl TableProviderFactory for ListingTableFactory { state: &dyn Session, cmd: &CreateExternalTable, ) -> Result> { - // TODO remove downcast_ref from here. Should file format factory be an extension to session state? + // TODO (https://github.com/apache/datafusion/issues/11600) remove downcast_ref from here. Should file format factory be an extension to session state? let session_state = state.as_any().downcast_ref::().unwrap(); let file_format = session_state .get_file_format_factory(cmd.file_type.as_str())