I have implemented the streaming pipeline using pipeline builder and everything works fine.It get upda