diff --git a/core/logs/alils/config.go b/core/logs/alils/config.go index d0b67c24..558db6a8 100755 --- a/core/logs/alils/config.go +++ b/core/logs/alils/config.go @@ -7,7 +7,7 @@ const ( // OffsetNewest is the log head offset, i.e. the offset that will be // assigned to the next message that will be produced to the shard. OffsetNewest = "end" - // OffsetOldest is the the oldest offset available on the logstore for a + // OffsetOldest is the oldest offset available on the logstore for a // shard. OffsetOldest = "begin" ) diff --git a/core/logs/log.go b/core/logs/log.go index 2dedc768..0cb798ac 100644 --- a/core/logs/log.go +++ b/core/logs/log.go @@ -188,7 +188,7 @@ func (bl *BeeLogger) AsyncNonBlockWrite() *BeeLogger { } // SetLogger provides a given logger adapter into BeeLogger with config string. -// config must in in JSON format like {"interval":360}} +// config must in JSON format like {"interval":360}} func (bl *BeeLogger) setLogger(adapterName string, configs ...string) error { config := append(configs, "{}")[0] for _, l := range bl.outputs { @@ -223,7 +223,7 @@ func (bl *BeeLogger) setLogger(adapterName string, configs ...string) error { } // SetLogger provides a given logger adapter into BeeLogger with config string. -// config must in in JSON format like {"interval":360}} +// config must in JSON format like {"interval":360}} func (bl *BeeLogger) SetLogger(adapterName string, configs ...string) error { bl.lock.Lock() defer bl.lock.Unlock()