Hey I have a question on the similar lines

I am using flink to consume events from kafka and having a sliding window assigner for 1 hour window slides every 5 mins and then it has to write result in cassandra. I want to understand how this works internally ??

For example we have 10000 events and 5 taskmanagers and let's say each taskmanager gets 2000 event so there will be 5 entries in cassandra or Flink internally will aggregate all the outputs from 5 taskmanager and then create a single entry in cassandra.