Skip to content
This repository has been archived by the owner on Jun 16, 2023. It is now read-only.

jstorm ShellSpout 用默认的JsonSerializer有bug #365

Open
yunfan123 opened this issue Oct 24, 2016 · 4 comments
Open

jstorm ShellSpout 用默认的JsonSerializer有bug #365

yunfan123 opened this issue Oct 24, 2016 · 4 comments

Comments

@yunfan123
Copy link
Contributor

在用ShellSpout的时候，因为AckSpout 和 ShellSpout 是不同的线程，但是他们都是从线程的stdout里面去读消息，导致读到的消息错乱。这一块如果是作为ShellSpout 的JsonSerializer在 readString 这个方法需要加锁。当然我不知道这个加锁之后对于其他的地方是否有性能相关的影响。
@hustfxj
Copy link
Collaborator

hustfxj commented Oct 24, 2016

spout 有两种模式， 你把spout.single.thread设置为true的话。ack 和spout就在同一线程，就不会发生你说的问题。不过我觉得你说的是一个问题，你可以fix的，要不你提交一个PR，我们帮你review下。

@hustfxj
Copy link
Collaborator

hustfxj commented Oct 24, 2016

@yunfan123

@yunfan123
Copy link
Contributor Author

OK

@yunfan123
Copy link
Contributor Author

@hustfxj .
看下这个 PR: #380

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@yunfan123 @hustfxj