streaming framework, probe commit control