incubator-s4-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Karthik Kambatla <kkamb...@cs.purdue.edu>
Subject Re: S4-7 Status update
Date Tue, 03 Jan 2012 23:20:46 GMT
Sorry for the false alarm.

The issue was that I was sending the messages multiple times. Fixed the
same, and it seems to be working fine. Shall submit the patch on S4-7.

Thanks
Karthik

On Tue, Jan 3, 2012 at 11:52 AM, Karthik Kambatla <kkambatl@cs.purdue.edu>wrote:

> Hi there
>
> S4-7 corresponds to making Netty robust. As we have discussed on the JIRA
> - https://issues.apache.org/jira/browse/S4-7, I have implemented the
> proposed approach - my github branch for the same -
> https://github.com/kambatla/s4-piper/tree/s4-7
>
> However, I am facing a couple of issues -
>
>    1. On send(), netty throws a callback for channels that I have no clue
>    about. I do some book-keeping for the channels I use, and the Channel that
>    Netty throws at me, I don't have any records.
>    2. I have written a bunch of tests - guaranteed message delivery,
>    message ordering on both single and multiple partitions using zookeeper and
>    they all run fine. However, my code fails the WordCountTestZk test, I so
>    far have not been able to figure out why.
>
> Please comment if you know what might be causing any of these two issues.
> Also, in light of #2, I am considering re-engineering the solution. So,
> please comment on better ways to go about the problem at hand.
>
> Thanks
> Karthik
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message