[GitHub] [streampipes] dominikriemer opened a new issue, #692: Flink "And" processor work not proper after "Number Labeler"

[GitBox <gi...@apache.org>]

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: issues-unsubscribe@streampipes.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [streampipes] dominikriemer closed issue #692: Flink "And" processor work not proper after "Number Labeler"

[GitBox <gi...@apache.org>]

dominikriemer closed issue #692: Flink "And" processor work not proper after "Number Labeler"
URL: https://github.com/apache/streampipes/issues/692


-- 
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: issues-unsubscribe@streampipes.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org