flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Sink not switched to "RUNUNG" even though a task slot is available
Date Wed, 23 Nov 2016 16:35:12 GMT
Hi Yassine,

you don't necessarily need to set the parallelism of the last two operators
of 31, the sink with parallelism 1 will fit still into the slots.
A task slot can, by default, hold an entire "slice" or parallel instance of
a job.

The reason why the sink stays in state CREATE in the beginning is because
it didn't receive any data yet. In batch mode, an operator is switching to
RUNNING once it received the first record. In your case, there are some
operations (reduce, join) before the sink that first need to consume all
data and process it.
If you wait long enough, you should see the sink to become active.


On Wed, Nov 23, 2016 at 2:03 PM, Yassine MARZOUGUI <
y.marzougui@mindlytix.com> wrote:

> Hi all,
> My batch job has the follwoing plan in the end (figure attached):
> ‚Äč
> I have a total of 32 task slots, and I have set the parallelism of the
> last two operators before the sink to 31. The sink parallelism is 1. The
> last operator before the sink is a MapOperator, so it doesn't need to
> buffer all elements before emitting the output.
> Looking at the dashboard, I see that one task slot is available, but the
> sink subtask stays in the state "CREATED".
> Any explanation for this behaviour? Thank you.
> Best,
> Yassine

View raw message