diff --git a/dbms/src/Flash/Coprocessor/DAGContext.h b/dbms/src/Flash/Coprocessor/DAGContext.h index dbd45362a55..6f0b46c45b1 100644 --- a/dbms/src/Flash/Coprocessor/DAGContext.h +++ b/dbms/src/Flash/Coprocessor/DAGContext.h @@ -380,8 +380,8 @@ class DAGContext private: std::shared_ptr process_list_entry; - /// Holding the table lock to make sure that the table wouldn't be dropped during the lifetime of this query, - /// even if there are no local regions. + /// Holding the table lock to make sure that the table wouldn't be dropped during the lifetime of this query, even if there are no local regions. + /// TableLockHolders need to be released after the BlockInputStream is destroyed to prevent data read exceptions. TableLockHolders table_locks; /// profile_streams_map is a map that maps from executor_id to profile BlockInputStreams. std::unordered_map profile_streams_map;