We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5f340cd commit a338232Copy full SHA for a338232
common/persistence/nosql/nosqlplugin/cassandra/tasks.go
@@ -89,6 +89,11 @@ func toTaskListPartitionConfig(v interface{}) *persistence.TaskListPartitionConf
89
version := partition["version"].(int64)
90
numRead := partition["num_read_partitions"].(int)
91
numWrite := partition["num_write_partitions"].(int)
92
+
93
+ if version == 0 && numRead == 0 && numWrite == 0 {
94
+ return nil
95
+ }
96
97
return &persistence.TaskListPartitionConfig{
98
Version: version,
99
NumReadPartitions: numRead,
0 commit comments