risingwave_stream::executor

Module troublemaker

source

Structs§

  • Inner 🔒
  • TroublemakerExecutor
    TroublemakerExecutor is used to make some trouble in the stream graph. Specifically, it is attached to StreamScan and Source executors in insane mode. It randomly corrupts the stream chunks it receives and sends them downstream, making the stream inconsistent. This should ONLY BE USED IN INSANE MODE FOR TESTING PURPOSES.
  • Vars 🔒