Hi Team, I am subscripting to platform event in Salesforce. Once the events are over I would like to generate event to stop the pipeline and also use the same event , append some fields and insert into Postgres.

I followed below article  https://stackoverflow.com/questions/61800532/how-to-transition-a-streamsets-pipeline-to-finished-state-if-the-origin-does-not  and I  was able to generate event using Jython and stop the pipeline. 

When I am trying to add fields to the event using Expression evaluator it throws java.illegalArgumentException. 

Request for assitance on how I can get this fixed