dominikriemer opened a new issue, #692: URL: https://github.com/apache/streampipes/issues/692
The first stream is "__Flow Rate 1__" with "__Number Labeler__" , when temperature lower than 900 then add a label value "low" to the event (this means it must be always "low"). The second stream is similar , from "__Flow Rate 2__" with "__Number Labeler__" and also add a label value "low" to the event of fluid_temperature lower than 900. After that the two stream events have same primitive string value "low". Flink "And" processor combines two streams with labeled field and time window is 5 seconds, but there is no data emit to data sink. Pipeline was exported and can see in attachment. Imported from Jira [STREAMPIPES-530](https://issues.apache.org/jira/browse/STREAMPIPES-530). Original Jira may contain additional context. Reported by: PatrickWong. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
