Akash Kadakia issues

Repositories
Issues
Comments

Results 1 issues of


                                            Akash Kadakia

[Bug]: Watermarks and Windowing Not Working with FlinkRunner and KinesisIO Read Transform

### What happened? When there are idle subtasks in flink, they dont propagate watermarks to downstream operators and thus windowing function that are based on watermarks never get triggered. I...

java

flink

bug