Skip to content
This repository has been archived by the owner on Nov 24, 2023. It is now read-only.

Commit

Permalink
address comment
Browse files Browse the repository at this point in the history
  • Loading branch information
@lance6716
lance6716 committed Jan 13, 2021
1 parent fa5f749 commit 76ed3ab
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion dm/common/common.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ var (
func keyAdapterKeysLen(s KeyAdapter) int {
switch s {
case WorkerRegisterKeyAdapter, UpstreamConfigKeyAdapter, UpstreamBoundWorkerKeyAdapter,
WorkerKeepAliveKeyAdapter, StageRelayKeyAdapter, TaskConfigKeyAdapter:
WorkerKeepAliveKeyAdapter, StageRelayKeyAdapter, TaskConfigKeyAdapter,
UpstreamLastBoundWorkerKeyAdapter:
return 1
case UpstreamSubTaskKeyAdapter, StageSubTaskKeyAdapter,
ShardDDLPessimismInfoKeyAdapter, ShardDDLPessimismOperationKeyAdapter,
Expand Down

0 comments on commit 76ed3ab

Please sign in to comment.