You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by "Dominik Riemer (Jira)" <ji...@apache.org> on 2022/11/26 15:22:00 UTC
[jira] [Commented] (STREAMPIPES-530) Flink "And" processor work not proper after "Number Labeler"
[ https://issues.apache.org/jira/browse/STREAMPIPES-530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639406#comment-17639406 ]
Dominik Riemer commented on STREAMPIPES-530:
--------------------------------------------
This issue has been migrated to https://github.com/apache/streampipes/issues/692
> Flink "And" processor work not proper after "Number Labeler"
> ------------------------------------------------------------
>
> Key: STREAMPIPES-530
> URL: https://issues.apache.org/jira/browse/STREAMPIPES-530
> Project: StreamPipes
> Issue Type: Bug
> Components: Pipeline Elements
> Affects Versions: 0.69.0
> Environment: use cli to create full env on 16GB memory laptop MacBook Pro (16-inch, 2019) .
> $ cat .env | fgrep SP_VERSION
> SP_VERSION=0.69.0
> $ cat .spenv | fgrep env
> [environment:full]
> $ docker-compose -version
> docker-compose version 1.29.2, build 5becea4c
> $ docker version
> Client:
> Cloud integration: v1.0.23
> Version: 20.10.14
> API version: 1.41
> Go version: go1.16.15
> Git commit: a224086
> Built: Thu Mar 24 01:49:20 2022
> OS/Arch: darwin/amd64
> Context: default
> Experimental: true
> Server: Docker Desktop 4.7.0 (77141)
> Engine:
> Version: 20.10.14
> API version: 1.41 (minimum version 1.12)
> Go version: go1.16.15
> Git commit: 87a90dc
> Built: Thu Mar 24 01:46:14 2022
> OS/Arch: linux/amd64
> Experimental: false
> containerd:
> Version: 1.5.11
> GitCommit: 3df54a852345ae127d1fa3092b95168e4a88e2f8
> runc:
> Version: 1.0.3
> GitCommit: v1.0.3-0-gf46b6ba
> docker-init:
> Version: 0.19.0
> GitCommit: de40ad0
> Reporter: Patrick Wong
> Priority: Critical
> Attachments: pipelines (6).json
>
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)