Tathagata determined that the reason it was failing was the accidental
creation of multiple input streams. Thanks!
On Tue, Jul 15, 2014 at 1:09 PM, Walrus theCat
wrote:
> Will do.
>
>
> On Tue, Jul 15, 2014 at 12:56 PM, Tathagata Das <
> tathagata.das1...@gmail.com> wrote:
>
>> This sounds rea
Will do.
On Tue, Jul 15, 2014 at 12:56 PM, Tathagata Das wrote:
> This sounds really really weird. Can you give me a piece of code that I
> can run to reproduce this issue myself?
>
> TD
>
>
> On Tue, Jul 15, 2014 at 12:02 AM, Walrus theCat
> wrote:
>
>> This is (obviously) spark streaming, by
This sounds really really weird. Can you give me a piece of code that I can
run to reproduce this issue myself?
TD
On Tue, Jul 15, 2014 at 12:02 AM, Walrus theCat
wrote:
> This is (obviously) spark streaming, by the way.
>
>
> On Mon, Jul 14, 2014 at 8:27 PM, Walrus theCat
> wrote:
>
>> Hi,
>
This is (obviously) spark streaming, by the way.
On Mon, Jul 14, 2014 at 8:27 PM, Walrus theCat
wrote:
> Hi,
>
> I've got a socketTextStream through which I'm reading input. I have three
> Dstreams, all of which are the same window operation over that
> socketTextStream. I have a four core ma
Hi,
I've got a socketTextStream through which I'm reading input. I have three
Dstreams, all of which are the same window operation over that
socketTextStream. I have a four core machine. As we've been covering
lately, I have to give a "cores" parameter to my StreamingSparkContext:
ssc = new St
