Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
0.69.0
-
None
-
None
-
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
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
Description
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.