Hi Krzysztof,
I agree with you that sometimes one may want to break chains so there's value
in supporting overriding parallelisms for individual operators. However, the
config pipeline.jobvertex-parallelism-overrides is added in the context of
support Flink autoscaling. For autoscaling, we don'
Hi Kenan,
Flink introduces the watchdog mechanism that makes TM suicide as the final
safety net for properly cancel a task that got stuck in the cancellation phase
for too long. The mechanism is necessary as there's no other alternatives to
force killing a stuck task other than killing the proc
Hello,
The issue I’m encountering revolves about
1、 aggregating products sales for each minute. Sale data from Kafka with
eventtime.
2、If there is no data in that minute, program should produces default zero.
3、all time I mention are eventtime. No using process time is consider of
rerun situation.
