Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-09-16 Thread Danijel Schiavuzzi
: Wednesday, June 4, 2014 at 10:30 AM To: user@storm.incubator.apache.org user@storm.incubator.apache.org, d...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-09-16 Thread M.Tarkeshwar Rao
: Wednesday, June 4, 2014 at 10:30 AM To: user@storm.incubator.apache.org user@storm.incubator.apache.org, d...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-09-16 Thread M.Tarkeshwar Rao
...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck) Hi all, I've managed to reproduce the stuck topology problem and it seems it's due to the Netty

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-07-17 Thread Danijel Schiavuzzi
user@storm.incubator.apache.org Date: Wednesday, June 4, 2014 at 10:30 AM To: user@storm.incubator.apache.org user@storm.incubator.apache.org, d...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-07-16 Thread M.Tarkeshwar Rao
-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck) Hi all, I've managed to reproduce the stuck topology problem and it seems it's due to the Netty transport. Running with ZMQ transport enabled now and I haven't been able to reproduce this. The problem

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-07-07 Thread M.Tarkeshwar Rao
AM To: user@storm.incubator.apache.org user@storm.incubator.apache.org, d...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck) Hi all, I've managed

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-07-03 Thread Danijel Schiavuzzi
@storm.incubator.apache.org user@storm.incubator.apache.org, d...@storm.incubator.apache.org d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck) Hi all, I've managed to reproduce

Re: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-06-16 Thread Bobby Evans
...@storm.incubator.apache.orgmailto:d...@storm.incubator.apache.org Subject: Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck) Hi all, I've managed to reproduce the stuck topology problem and it seems it's due to the Netty transport

Trident transactional topology stuck re-emitting batches with Netty, but running fine with ZMQ (was Re: Topology is stuck)

2014-06-04 Thread Danijel Schiavuzzi
Hi all, I've managed to reproduce the stuck topology problem and it seems it's due to the Netty transport. Running with ZMQ transport enabled now and I haven't been able to reproduce this. The problem is basically a Trident/Kafka transactional topology getting stuck, i.e. re-emitting the same