Patrick Wong created STREAMPIPES-530:
----------------------------------------
Summary: 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
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.1#820001)
