Update StreamEventPopulaterFactory.java
A StreamMappingElement is created on line 46, and on line 47 the fromPosition is set. By creating new elements here, the fromPosition is lost and reset to 0, leading to the the wrong values being selected (all values taken from field 0).
@@ -51,15 +51,12 @@ public class StreamEventPopulaterFactory {
} else {
index = metaStreamEvent.getOnAfterWindowData().indexOf(attribute);
if (index > -1) {
- streamMappingElement = new StreamMappingElement();
streamMappingElement.setToPosition(new int[]{streamEventChainIndex, 0, ON_AFTER_WINDOW_DATA_INDEX, index});
} else {
index = metaStreamEvent.getBeforeWindowData().indexOf(attribute);
if (index > -1) {
- streamMappingElement = new StreamMappingElement();
streamMappingElement.setToPosition(new int[]{streamEventChainIndex, 0, BEFORE_WINDOW_DATA_INDEX, index});
} else {
- streamMappingElement = new StreamMappingElement();
streamMappingElement.setToPosition(null);
}
}
