nickscut

version:1.3.1

from cmd of bin/kuiper getstatus rule cz110201Double_MB1_tuple_3_attr Three streams of data have been increasing

select cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode as assetCode, window_end() * 1000000 as ts, ((collect(cz110201Double_MB1_cz110201Int_MB10012.Data[0]->Value)[-1])+(collect(cz110201Double_MB1_cz110201Int_MB10011.Data[0]->Value)[-1])+(collect(cz110201Double_MB1_cz110201Int_MB10010.Data[0]->Value)[-1])) as calValue from cz110201Double_MB1_cz110201Int_MB10012 left join cz110201Double_MB1_cz110201Int_MB10011 on cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode = cz110201Double_MB1_cz110201Int_MB10011.Data[0]->AssetCode left join cz110201Double_MB1_cz110201Int_MB10010 on cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode = cz110201Double_MB1_cz110201Int_MB10010.Data[0]->AssetCode group by...

 No exception can be seen through the log

cz110201Double_MB1_cz110201Int_MB10012 left join cz110201Double_MB1_cz110201Int_MB10011 There is a result returned cz110201Double_MB1_cz110201Int_MB10012 left join cz110201Double_MB1_cz110201Int_MB10010 There is a result returned but cz110201Double_MB1_cz110201Int_MB10012 left join cz110201Double_MB1_cz110201Int_MB10011 left join cz110201Double_MB1_cz110201Int_MB10010 No results have been...

My SQL syntax is incorrect?

select cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode as assetCode, window_end() * 1000000 as ts, ((collect(cz110201Double_MB1_cz110201Int_MB10012.Data[0]->Value)[-1])+(collect(cz110201Double_MB1_cz110201Int_MB10011.Data[0]->Value)[-1])+(collect(cz110201Double_MB1_cz110201Int_MB10010.Data[0]->Value)[-1])) as calValue from cz110201Double_MB1_cz110201Int_MB10012 left join cz110201Double_MB1_cz110201Int_MB10011 on cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode = cz110201Double_MB1_cz110201Int_MB10011.Data[0]->AssetCode left join cz110201Double_MB1_cz110201Int_MB10010 on cz110201Double_MB1_cz110201Int_MB10012.Data[0]->AssetCode = cz110201Double_MB1_cz110201Int_MB10010.Data[0]->AssetCode group by...

cz110201Double_MB1_cz110201Int_MB10012： {"Data":[{"AssetId":"DK_110201_0126","AttributeId":"DK_110201_0126\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0126","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":0,"Quality":0,"Timestamp":1638513296015226739}]} {"Data":[{"AssetId":"DK_110201_0066","AttributeId":"DK_110201_0066\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0066","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296038547873}]} {"Data":[{"AssetId":"DK_110201_0129","AttributeId":"DK_110201_0129\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0129","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296038547873}]} {"Data":[{"AssetId":"DK_110201_0192","AttributeId":"DK_110201_0192\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0192","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296038547873}]} {"Data":[{"AssetId":"DK_110201_0003","AttributeId":"DK_110201_0003\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0003","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296038547873}]} {"Data":[{"AssetId":"DK_110201_0158","AttributeId":"DK_110201_0158\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0158","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":0,"Quality":0,"Timestamp":1638513296067651394}]} {"Data":[{"AssetId":"DK_110201_0032","AttributeId":"DK_110201_0032\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0032","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":0,"Quality":0,"Timestamp":1638513296067651394}]} {"Data":[{"AssetId":"DK_110201_0095","AttributeId":"DK_110201_0095\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0095","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":0,"Quality":0,"Timestamp":1638513296067651394}]} {"Data":[{"AssetId":"DK_110201_0195","AttributeId":"DK_110201_0195\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0195","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296093107464}]} {"Data":[{"AssetId":"DK_110201_0069","AttributeId":"DK_110201_0069\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0069","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296093107464}]} {"Data":[{"AssetId":"DK_110201_0132","AttributeId":"DK_110201_0132\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0132","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296093107464}]} {"Data":[{"AssetId":"DK_110201_0006","AttributeId":"DK_110201_0006\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0006","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296093107464}]} {"Data":[{"AssetId":"DK_110201_0150","AttributeId":"DK_110201_0150\u0026cz110201Int_MB10012","AssetCode":"DK_110201_0150","AttributeCode":"cz110201Int_MB10012","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10012","Value":1,"Quality":0,"Timestamp":1638513296100850890}]} cz110201Double_MB1_cz110201Int_MB10011： {"Data":[{"AssetId":"DK_110201_0126","AttributeId":"DK_110201_0126\u0026cz110201Int_MB10011","AssetCode":"DK_110201_0126","AttributeCode":"cz110201Int_MB10011","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10011","Value":0,"Quality":0,"Timestamp":1638513354029289175}]} {"Data":[{"AssetId":"DK_110201_0066","AttributeId":"DK_110201_0066\u0026cz110201Int_MB10011","AssetCode":"DK_110201_0066","AttributeCode":"cz110201Int_MB10011","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10011","Value":1,"Quality":0,"Timestamp":1638513354053404068}]} cz110201Double_MB1_cz110201Int_MB10010： {"Data":[{"AssetId":"DK_110201_0126","AttributeId":"DK_110201_0126\u0026cz110201Int_MB10010","AssetCode":"DK_110201_0126","AttributeCode":"cz110201Int_MB10010","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10010","Value":0,"Quality":0,"Timestamp":1638513410043819554}]} {"Data":[{"AssetId":"DK_110201_0066","AttributeId":"DK_110201_0066\u0026cz110201Int_MB10010","AssetCode":"DK_110201_0066","AttributeCode":"cz110201Int_MB10010","AttributeGroupName":"B","AttributeName":"cz110201Int_MB10010","Value":1,"Quality":0,"Timestamp":1638513410067138903}]}

I am sure that the three streams have the same device data coming in in the window

Take the latest value of the three streams in the TUMBLINGWINDOW