flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Windowing isn't applied per key
Date Tue, 10 Oct 2017 16:40:21 GMT
Hi,

Could you maybe give an example of what you expect as output and what you actually get? 

Best,
Aljoscha

> On 9. Oct 2017, at 16:09, mclendenin <marcuscbey@gmail.com> wrote:
> 
> I am using Processing Time, so it is using the default timestamps and
> watermarks. I am running it with a parallelism of 3, I can see each operator
> running at a parallelism of 3 on the Web UI. I am pulling data from a Kafka
> topic with 12 partitions. 
> 
> 
> 
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/


Mime
View raw message