ream b = new ByteArrayOutputStream();
> ObjectOutputStream o = new ObjectOutputStream(b);
> o.writeObject(map);
> bytes = b.toByteArray();
>
> -Original Message-
> From: Yi Pan [mailto:nickpa...@gmail.com]
> Sent: Wednesday, September 02, 2015 10:31 PM
> To: d
...@gmail.com]
Sent: Wednesday, September 02, 2015 10:31 PM
To: dev@samza.apache.org
Subject: Re: One task sending payload to multiple output streams
Hi, Elangovan,
Could you confirm how many containers in your job? And how is the outgoing
messages partitioned on? Most likely, this is related
015 1:12 PM
> To: dev@samza.apache.org
> Subject: RE: One task sending payload to multiple output streams
>
> Hi,
>
> How many input streams does this task consume and how are they partitioned?
>
> Garry
>
> -Original Message-
> From: Balusamy, Elangovan
The task consumes from one stream with 2 partitions.
-Original Message-
From: Garry Turkington [mailto:g.turking...@improvedigital.com]
Sent: Wednesday, September 02, 2015 1:12 PM
To: dev@samza.apache.org
Subject: RE: One task sending payload to multiple output streams
Hi,
How many
Hi,
How many input streams does this task consume and how are they partitioned?
Garry
-Original Message-
From: Balusamy, Elangovan [mailto:elangovan.balus...@altisource.com]
Sent: 02 September 2015 08:19
To: dev@samza.apache.org
Cc: Chandra, Saurabh
Subject: One task sending payload to
