diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-02-03 21:34:32 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-02-03 21:34:32 +0500 |
| commit | 2fb4c605403275067a2837ce54735b1d09ed9883 (patch) | |
| tree | a365af13a907311d0357ca8fc9d7173d9f55798e | |
| parent | 24ec17219be00f8c00e1f56412b5dd929028d8b5 (diff) | |
| download | seaweedfs-2fb4c605403275067a2837ce54735b1d09ed9883.tar.xz seaweedfs-2fb4c605403275067a2837ce54735b1d09ed9883.zip | |
fix log warn
| -rw-r--r-- | weed/replication/sub/notification_gocdk_pub_sub.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sub/notification_gocdk_pub_sub.go b/weed/replication/sub/notification_gocdk_pub_sub.go index 432f61745..413c0e3cf 100644 --- a/weed/replication/sub/notification_gocdk_pub_sub.go +++ b/weed/replication/sub/notification_gocdk_pub_sub.go @@ -121,7 +121,7 @@ func (k *GoCDKPubSubInput) ReceiveMessage() (key string, message *filer_pb.Event var delivery amqp.Delivery if msg.As(&delivery) { isRedelivered = delivery.Redelivered - glog.Warning("onFailureFn() metadata: %+v, redelivered: %v", msg.Metadata, delivery.Redelivered) + glog.Warningf("onFailureFn() metadata: %+v, redelivered: %v", msg.Metadata, delivery.Redelivered) } if isRedelivered { if err := delivery.Nack(false, false); err != nil { |