diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-17 10:01:11 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-17 10:01:11 -0700 |
| commit | ffa69b24ae0b5daf6cb040c95bb821c25ba15461 (patch) | |
| tree | eb1e500483403d79e4aff26dad6e966e192cbbcb /weed/messaging/broker_append.go | |
| parent | 3f3dba5a68287da6a5a8e87945c1eca2bcf925f6 (diff) | |
| download | seaweedfs-ffa69b24ae0b5daf6cb040c95bb821c25ba15461.tar.xz seaweedfs-ffa69b24ae0b5daf6cb040c95bb821c25ba15461.zip | |
fix travis
Diffstat (limited to 'weed/messaging/broker_append.go')
| -rw-r--r-- | weed/messaging/broker_append.go | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/weed/messaging/broker_append.go b/weed/messaging/broker_append.go index 07b3755c0..a0c0e8614 100644 --- a/weed/messaging/broker_append.go +++ b/weed/messaging/broker_append.go @@ -58,7 +58,6 @@ func (broker *MessageBroker) appendToFile(targetFile string, topicConfig *messag func (broker *MessageBroker) assignAndUpload(topicConfig *messaging_pb.TopicConfiguration, data []byte) (*operation.AssignResult, *operation.UploadResult, error) { var assignResult = &operation.AssignResult{} - var collection, replication string // assign a volume location if err := broker.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error { @@ -84,8 +83,6 @@ func (broker *MessageBroker) assignAndUpload(topicConfig *messaging_pb.TopicConf assignResult.PublicUrl = resp.PublicUrl assignResult.Count = uint64(resp.Count) - collection, replication = resp.Collection, resp.Replication - return nil }); err != nil { return nil, nil, err |