[ 
https://issues.apache.org/jira/browse/STREAMPIPES-449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435291#comment-17435291
 ] 

Philipp Zehnder commented on STREAMPIPES-449:
---------------------------------------------

Hi,

I tested it locally, also with the System.out.println statement.
 * the declare model is called when the service is started 
 * The on invocation is called on pipeline start
 * For each event the onEvent Method is triggered
 * And once the pipeline is stopped the onDetach is called

For some reason the declare model is called quite often, we have to look into 
this because this should not be the case.

Did you search your logs? Maybe the output is hidden between some other logs in 
the console.

Is the data processed correctly in StreamPipes or is there also a problem?

Philipp

 

> Update Processing Element API in module streampipes-processors-filters-jvm
> --------------------------------------------------------------------------
>
>                 Key: STREAMPIPES-449
>                 URL: https://issues.apache.org/jira/browse/STREAMPIPES-449
>             Project: StreamPipes
>          Issue Type: Improvement
>          Components: Pipeline Elements
>            Reporter: Philipp Zehnder
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 0.69.0
>
>         Attachments: Screenshot from 2021-10-28 01-26-31.png, Screenshot from 
> 2021-10-28 01-27-33.png
>
>
> The processors in this module use the old API, where 3 classes are required 
> for a single processing element. 
> These should be updated to use StreamPipesDataProcessor instead of 
> StreamPipesDataProcessor.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to