Skip to content

Commit c236d51

Browse files
committed
Remove buffer on PanicAbort channel
1 parent 7b47215 commit c236d51

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

go/base/context.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -324,7 +324,7 @@ func NewMigrationContext() *MigrationContext {
324324
pointOfInterestTimeMutex: &sync.Mutex{},
325325
lastHeartbeatOnChangelogMutex: &sync.Mutex{},
326326
ColumnRenameMap: make(map[string]string),
327-
PanicAbort: make(chan error, 1),
327+
PanicAbort: make(chan error),
328328
ctx: ctx,
329329
cancelFunc: cancelFunc,
330330
abortMutex: &sync.Mutex{},

0 commit comments

Comments
 (0)