parallelism increases the end2end latency in
flink sql
Hi,
My application assigned timestamp to kafka event
with BoundedOutOfOrdernessTimestampExtractor then converted them to a
table. Finally flink SQLover-window aggregation is run against the table.
When I double the parallelism of my flink
y 23, 2018 3:21:24 PM
To: user@flink.apache.org
Subject: increasing parallelism increases the end2end latency in flink sql
Hi,
My application assigned timestamp to kafka event with
BoundedOutOfOrdernessTimestampExtractor then converted them to a table. Finally
flink SQL over-window aggreg
Hi,
My application assigned timestamp to kafka event with
BoundedOutOfOrdernessTimestampExtractor then converted them to a table. Finally
flink SQL over-window aggregation is run against the table.
When I double the parallelism of my flink application, the end2end latency is
doubled. What c
