cross available CPUs, not
> available slots on the closest host.
> Is there a way to achieve that?
>
>
> ------------------
> Date: Thu, 12 Mar 2015 20:28:29 +0100
> Subject: Re: Flink logs only written to one host
> From: gyf...@apache.org
> To: user@flink.
5 20:28:29 +0100
Subject: Re: Flink logs only written to one host
From: gyf...@apache.org
To: user@flink.apache.org
Hey,
Let me clarify some things regarding distribute(). You should only specify a
partitioning scheme like distribute or shuffle or groupby in cases when it
actually matters for y
that fixed that issue for me for now.. .looking forward to learning
> more about Flink
>
> ------
> Date: Thu, 12 Mar 2015 20:00:32 +0100
> Subject: RE: Flink logs only written to one host
> From: fhue...@gmail.com
> To: user@flink.apache.org
>
>
>
Flink
Date: Thu, 12 Mar 2015 20:00:32 +0100
Subject: RE: Flink logs only written to one host
From: fhue...@gmail.com
To: user@flink.apache.org
Can you check the JM log file how many slots are available?
Slots are configured per TM. If you configure 9 slots and 3 TMs you end up with
27 slots, 9 on e
----
> From: ele...@msn.com
> To: user@flink.apache.org
> Subject: Flink logs only written to one host
> Date: Thu, 12 Mar 2015 17:30:28 +
>
> Hello,
>
> I'm using a 3 nodes (3VMs) cluster, 3CPUs each, parallelism of 9,
> I usually only see taskmanager.out logs g
written to one host
Date: Thu, 12 Mar 2015 17:30:28 +
Hello,
I'm using a 3 nodes (3VMs) cluster, 3CPUs each, parallelism of 9, I usually
only see taskmanager.out logs generated only on one of the 3 nodes when I use
the System.out.println() method, to print debug info in my main proce
Hello,
I'm using a 3 nodes (3VMs) cluster, 3CPUs each, parallelism of 9, I usually
only see taskmanager.out logs generated only on one of the 3 nodes when I use
the System.out.println() method, to print debug info in my main processing
function.
Is this expected? Or am I just doing something wro
