faust icon indicating copy to clipboard operation
faust copied to clipboard

Missing sensor state for rebalance #1

Open haoyun opened this issue 4 years ago • 0 comments

Checklist

  • [x] I have included information about relevant versions
  • [x] I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

MWE:

import faust

app = faust.App('myapp')

if __name__ == "__main__":
    app.main()
python test.py worker

Expected behavior

no warnning

Actual behavior

starting➢ 😊
◦[2021-01-22 23:50:16,167] [414000] [WARNING] [^-App]: Missing sensor state for rebalance #1 
[2021-01-22 23:50:16,181] [414000] [WARNING] [^-App]: Missing sensor state for rebalance #1 

The same warning also appeared in https://github.com/faust-streaming/faust/issues/44.

Full traceback

Versions

  • Python version 3.8.5
  • Faust version 0.4.3
  • Operating system Fedora 32 5.10.8-100.fc32.x86_64
  • Kafka version 2.13-2.6.0
  • RocksDB version (if applicable)

This was introduced in 0.2.0. It won't happen in 0.1.1. The signal

https://github.com/faust-streaming/faust/blob/5cce14580e3c50fd6ddfe3373ed595bd3a69914e/faust/tables/recovery.py#L241

was changed from reset to start in 0.2.0, somehow causing

https://github.com/faust-streaming/faust/blob/fda7e5264a4e19321e286d3151a0e0bb56ee5545/faust/app/base.py#L1611-L1612

clears the sensor state.

haoyun avatar Jan 22 '21 23:01 haoyun