Thanks for validating!
Guozhang
On Fri, Jun 17, 2016 at 7:39 PM, Tim Renner
wrote:
> Hi Guozhang,
>
> Apologies for the delay - had to convert to the new groupBy. The fix got
> rid of the error.
>
> Thanks!
>
> Tim
>
--
-- Guozhang
Hi Guozhang,
Apologies for the delay - had to convert to the new groupBy. The fix got
rid of the error.
Thanks!
Tim
Hello Tim,
I think I found the issue, could you apply the following patch and retry
your app?
https://github.com/apache/kafka/pull/1520
Guozhang
On Thu, Jun 16, 2016 at 11:11 PM, Guozhang Wang wrote:
> Hello Tim,
>
> By looking through the source code I suspect it is a bug in Kafka Stream's
Hello Tim,
By looking through the source code I suspect it is a bug in Kafka
Stream's KStreamWindowReduce
implementation. I'll do further investigation tomorrow and possibly file a
JIRA with a patch.
Guozhang
On Thu, Jun 16, 2016 at 4:12 PM, Tim Renner
wrote:
> Hi all,
>
> I'm trying to do a
Hi all,
I'm trying to do a KTable-KTable join to compute an average within a
tumbling window.
Here's the KStreams code (I've put a fully working example in a gist:
https://gist.github.com/timothyrenner/a99c86b2d6ed2c22c8703e8c7760af3a)
KStreamBuilder builder = new KStreamBuilder();
KStream longs
