robinhood / faust

Python Stream Processing
Other
6.72k stars 535 forks source link

Hopping Window return empty list #709

Closed jefferyng33106 closed 3 years ago

jefferyng33106 commented 3 years ago

Checklist

Steps to reproduce

Hello, I am trying to understand how the table + windowing works

The issue is when I use:

  1. multiple partition + no matter it's store://rocksdb or memory
  2. or in local mode with only 1 partition + rocksdb

Also I've checked:

But using export NO_CYTHON=True is not working

what I expect:

["dummy message 1", "dummy message 2"]

But what I get:

[]  # -> always empty list

Versions