Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug] Get uncorrect time value of attributes #1781

Closed
2 tasks done
hawickhuang opened this issue Nov 10, 2021 · 2 comments · Fixed by #1782
Closed
2 tasks done

[Bug] Get uncorrect time value of attributes #1781

hawickhuang opened this issue Nov 10, 2021 · 2 comments · Fixed by #1782
Assignees
Labels
Milestone

Comments

@hawickhuang
Copy link

What happened

get attributes like:

map[jbid: xxxxxx cnt: 1 dt:56407224 msgUUID:f38e3e98-4fe9-4f42-85a0-c412b075d1 tid: xxxxxxxx],

What you expected to happen

the value of dt should be like: 1630485910;

How to reproduce

for {
time.Sleep(10 * time.Second)
cr, _ := cli.GetMessage()
if err != nil {
log.Errorf("failed to get message: %v", err)
time.Sleep(1 * time.Second)
continue
}
for _, msg := range cr.Messages {
log.Infof("msg id: %d, topic: %s", msg.ID, msg.Topic)
m, err := tdmsg.New(msg.Data)
log.Debug("m: ", spew.Sdump(m.IsNumBid), spew.Sdump(m.CreateTime), spew.Sdump(m.Version),
spew.Sdump(m.AttrCount), spew.Sdump(m.MsgCount))
if err != nil {
log.Errorf("failed to parse td msg: %v", err)
time.Sleep(1 * time.Second)
break
}
....
}

Environment

linux

InLong version

master

InLong Component

InLong TubeMQ

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

@gosonzhang
Copy link
Contributor

@hawickhuang, thanks!

@TszKitLo40
Copy link
Contributor

@hawickhuang Thanks, I will fix it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging a pull request may close this issue.

3 participants