Skip to content

Commit 13c7592

Browse files
author
chengyitian
committed
AJ-646: fix issue about when EventHandler subscribe decimal data;
1 parent d733957 commit 13c7592

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/com/xxdb/streaming/cep/EventHandler.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,11 @@ public boolean deserializeEvent(List<IMessage> msgs, List<String> eventTypes, Li
244244
for (int i = 0; i < attrCount; ++i) {
245245
Entity.DATA_FORM form = scheme.getAttrForms().get(i);
246246
Entity.DATA_TYPE type = scheme.getAttrTypes().get(i);
247-
int extraParam = scheme.getAttrExtraParams().get(i);
247+
int extraParam;
248+
if (Objects.nonNull(scheme.getAttrExtraParams().get(i)))
249+
extraParam = scheme.getAttrExtraParams().get(i);
250+
else
251+
extraParam = -1;
248252

249253
try {
250254
if (form == Entity.DATA_FORM.DF_SCALAR) {

0 commit comments

Comments
 (0)