You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Xiang Wang <xi...@gmail.com> on 2016/03/19 02:15:01 UTC
define a cycle in storm topology
Hello,
I come with a requirement where bolt A needs to receive stream from bolt B
while blot B also needs to receive some stream updates from blot A.
Is it possible to define such a cycle topology in storm?
If not possible, is there any way to achieve this?
Thanks in advance for your kind help.
Best,
Xiang
Re: define a cycle in storm topology
Posted by Xiang Wang <xi...@gmail.com>.
Hi Ravi,
Thank you for your kind reply. I have solved this problem based your
suggestion.
Thanks:)
Best,
Xiang
-------------------------------
Xiang Wang PhD Candidate
Database Research Group
School of Computer Science and Engineering
The University of New South Wales
Sydney, Australia
On Tue, Mar 22, 2016 at 9:10 PM, Ravi Sharma <pi...@gmail.com> wrote:
> Hi Ziang,
> I think you should be able to define it. But you will have to make sure
> that you wont go into infinite loop.
>
> Ravi.
>
> On Tue, Mar 22, 2016 at 3:44 AM, Xiang Wang <xi...@gmail.com> wrote:
>
>> Does anyone could help?
>> Thanks.
>>
>>
>> -------------------------------
>> Xiang Wang PhD Candidate
>> Database Research Group
>> School of Computer Science and Engineering
>> The University of New South Wales
>> Sydney, Australia
>>
>> On Sat, Mar 19, 2016 at 12:15 PM, Xiang Wang <xi...@gmail.com> wrote:
>>
>>> Hello,
>>>
>>> I come with a requirement where bolt A needs to receive stream from bolt
>>> B while blot B also needs to receive some stream updates from blot A.
>>>
>>> Is it possible to define such a cycle topology in storm?
>>> If not possible, is there any way to achieve this?
>>>
>>> Thanks in advance for your kind help.
>>>
>>> Best,
>>> Xiang
>>>
>>>
>>
>
Re: define a cycle in storm topology
Posted by Xiang Wang <xi...@gmail.com>.
Hi Sai,
Thank you for your kind reply. The problem has been solved based your
suggestion.
Actually, there is no need to add bolt C. We can simply redirect the output
of B to A by adding B as one of A's incoming stream sources.
Best,
Xiang
-------------------------------
Xiang Wang PhD Candidate
Database Research Group
School of Computer Science and Engineering
The University of New South Wales
Sydney, Australia
On Wed, Mar 23, 2016 at 3:31 AM, Sai Dilip Reddy Kiralam <
dkiralam@aadhya-analytics.com> wrote:
> Hi Ziang,
>
> I think you should add one more bolt C which takes the stream updates from
> B and give those to update streams to A.
>
>
>
> *Best regards,*
>
> *K.Sai Dilip Reddy*
>
> On Tue, Mar 22, 2016 at 3:40 PM, Ravi Sharma <pi...@gmail.com> wrote:
>
>> Hi Ziang,
>> I think you should be able to define it. But you will have to make sure
>> that you wont go into infinite loop.
>>
>> Ravi.
>>
>> On Tue, Mar 22, 2016 at 3:44 AM, Xiang Wang <xi...@gmail.com> wrote:
>>
>>> Does anyone could help?
>>> Thanks.
>>>
>>>
>>> -------------------------------
>>> Xiang Wang PhD Candidate
>>> Database Research Group
>>> School of Computer Science and Engineering
>>> The University of New South Wales
>>> Sydney, Australia
>>>
>>> On Sat, Mar 19, 2016 at 12:15 PM, Xiang Wang <xi...@gmail.com>
>>> wrote:
>>>
>>>> Hello,
>>>>
>>>> I come with a requirement where bolt A needs to receive stream from
>>>> bolt B while blot B also needs to receive some stream updates from blot A.
>>>>
>>>> Is it possible to define such a cycle topology in storm?
>>>> If not possible, is there any way to achieve this?
>>>>
>>>> Thanks in advance for your kind help.
>>>>
>>>> Best,
>>>> Xiang
>>>>
>>>>
>>>
>>
>
Re: define a cycle in storm topology
Posted by Sai Dilip Reddy Kiralam <dk...@aadhya-analytics.com>.
Hi Ziang,
I think you should add one more bolt C which takes the stream updates from
B and give those to update streams to A.
*Best regards,*
*K.Sai Dilip Reddy*
On Tue, Mar 22, 2016 at 3:40 PM, Ravi Sharma <pi...@gmail.com> wrote:
> Hi Ziang,
> I think you should be able to define it. But you will have to make sure
> that you wont go into infinite loop.
>
> Ravi.
>
> On Tue, Mar 22, 2016 at 3:44 AM, Xiang Wang <xi...@gmail.com> wrote:
>
>> Does anyone could help?
>> Thanks.
>>
>>
>> -------------------------------
>> Xiang Wang PhD Candidate
>> Database Research Group
>> School of Computer Science and Engineering
>> The University of New South Wales
>> Sydney, Australia
>>
>> On Sat, Mar 19, 2016 at 12:15 PM, Xiang Wang <xi...@gmail.com> wrote:
>>
>>> Hello,
>>>
>>> I come with a requirement where bolt A needs to receive stream from bolt
>>> B while blot B also needs to receive some stream updates from blot A.
>>>
>>> Is it possible to define such a cycle topology in storm?
>>> If not possible, is there any way to achieve this?
>>>
>>> Thanks in advance for your kind help.
>>>
>>> Best,
>>> Xiang
>>>
>>>
>>
>
Re: define a cycle in storm topology
Posted by Ravi Sharma <pi...@gmail.com>.
Hi Ziang,
I think you should be able to define it. But you will have to make sure
that you wont go into infinite loop.
Ravi.
On Tue, Mar 22, 2016 at 3:44 AM, Xiang Wang <xi...@gmail.com> wrote:
> Does anyone could help?
> Thanks.
>
>
> -------------------------------
> Xiang Wang PhD Candidate
> Database Research Group
> School of Computer Science and Engineering
> The University of New South Wales
> Sydney, Australia
>
> On Sat, Mar 19, 2016 at 12:15 PM, Xiang Wang <xi...@gmail.com> wrote:
>
>> Hello,
>>
>> I come with a requirement where bolt A needs to receive stream from bolt
>> B while blot B also needs to receive some stream updates from blot A.
>>
>> Is it possible to define such a cycle topology in storm?
>> If not possible, is there any way to achieve this?
>>
>> Thanks in advance for your kind help.
>>
>> Best,
>> Xiang
>>
>>
>
Re: define a cycle in storm topology
Posted by Xiang Wang <xi...@gmail.com>.
Does anyone could help?
Thanks.
-------------------------------
Xiang Wang PhD Candidate
Database Research Group
School of Computer Science and Engineering
The University of New South Wales
Sydney, Australia
On Sat, Mar 19, 2016 at 12:15 PM, Xiang Wang <xi...@gmail.com> wrote:
> Hello,
>
> I come with a requirement where bolt A needs to receive stream from bolt B
> while blot B also needs to receive some stream updates from blot A.
>
> Is it possible to define such a cycle topology in storm?
> If not possible, is there any way to achieve this?
>
> Thanks in advance for your kind help.
>
> Best,
> Xiang
>
>