importccl: add pausepoint after import

Release note: none.
cockroachdb · Feb 12, 2022 · faa731a · faa731a
1 parent 4bba990
commit faa731a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/ccl/importccl/import_job.go b/pkg/ccl/importccl/import_job.go
@@ -283,6 +283,9 @@ func (r *importResumer) Resume(ctx context.Context, execCtx interface{}) error {
 			return err
 		}
 	}
+	if err := p.ExecCfg().JobRegistry.CheckPausepoint("import.after_ingest"); err != nil {
+		return err
+	}
 
 	// If the table being imported into referenced UDTs, ensure that a concurrent
 	// schema change on any of the typeDescs has not modified the type descriptor. If