Skip to content

Commit fc128c7

Browse files
committed
changefeedccl: fix table drop shutdown for enriched envelope
Fixes a bug where feeds with enriched envelopes and a `source` field could treat table drops as transient errors. Fixes: #148216 Release note: None
1 parent 8138e3f commit fc128c7

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

pkg/ccl/changefeedccl/enriched_source_provider.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -540,6 +540,9 @@ func getDescriptors(
540540
return nil
541541
}
542542
if err := execCfg.InternalDB.DescsTxn(ctx, f, isql.WithPriority(admissionpb.NormalPri)); err != nil {
543+
if errors.Is(err, catalog.ErrDescriptorDropped) {
544+
err = changefeedbase.WithTerminalError(err)
545+
}
543546
return nil, nil, nil, err
544547
}
545548
return tableDescriptor, dbDescriptor, schemaDescriptor, nil

0 commit comments

Comments
 (0)