sink needs to be drained

[vsmkarthikeyan]

the code has potential issue when we flip back and forth between fields and the first time when the field is valid it adds to the stream and never removes the valid value so what happens is even if the invalid value added it never considers it