Add fail point pause_after_copr_streams_acquired_once (#4833)

close #4868
pingcap · May 12, 2022 · c49258b · c49258b
1 parent 506df23
commit c49258b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/dbms/src/Common/FailPoint.cpp b/dbms/src/Common/FailPoint.cpp
@@ -91,7 +91,8 @@ std::unordered_map<String, std::shared_ptr<FailPointChannel>> FailPointHelper::f
     M(pause_until_dt_background_delta_merge)      \
     M(pause_before_apply_raft_cmd)                \
     M(pause_before_apply_raft_snapshot)           \
-    M(pause_until_apply_raft_snapshot)
+    M(pause_until_apply_raft_snapshot)            \
+    M(pause_after_copr_streams_acquired_once)
 
 #define APPLY_FOR_FAILPOINTS_WITH_CHANNEL(M) \
     M(pause_when_reading_from_dt_stream)     \

diff --git a/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp b/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp
@@ -51,6 +51,7 @@ extern const char region_exception_after_read_from_storage_all_error[];
 extern const char pause_with_alter_locks_acquired[];
 extern const char force_remote_read_for_batch_cop[];
 extern const char pause_after_copr_streams_acquired[];
+extern const char pause_after_copr_streams_acquired_once[];
 } // namespace FailPoints
 
 namespace
@@ -295,6 +296,7 @@ void DAGStorageInterpreter::executeImpl(DAGPipeline & pipeline)
     /// Set the limits and quota for reading data, the speed and time of the query.
     setQuotaAndLimitsOnTableScan(context, pipeline);
     FAIL_POINT_PAUSE(FailPoints::pause_after_copr_streams_acquired);
+    FAIL_POINT_PAUSE(FailPoints::pause_after_copr_streams_acquired_once);
 
     /// handle timezone/duration cast for local and remote table scan.
     executeCastAfterTableScan(remote_read_streams_start_index, pipeline);