faust
faust copied to clipboard
Missing sensor state for rebalance #1
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.