Use new ReplayablTableRecord in onAddError
@@ -39,6 +39,7 @@ import io.siddhi.core.util.config.ConfigReader;
import io.siddhi.core.util.error.handler.model.ErroneousEvent;
import io.siddhi.core.util.error.handler.util.ErrorOccurrence;
import io.siddhi.core.util.error.handler.util.ErrorStoreHelper;
+import io.siddhi.core.util.error.handler.util.ReplayableTableRecord;
import io.siddhi.core.util.parser.helper.QueryParserHelper;
import io.siddhi.core.util.statistics.LatencyTracker;
import io.siddhi.core.util.statistics.MemoryCalculable;
@@ -153,7 +154,8 @@ public abstract class Table implements FindableProcessor, MemoryCalculable {
switch (errorAction) {
case STORE:
addingEventChunk.reset();
- ErroneousEvent erroneousEvent = new ErroneousEvent(addingEventChunk, e, e.getMessage());
+ ErroneousEvent erroneousEvent = new ErroneousEvent(new ReplayableTableRecord(addingEventChunk), e,
+ e.getMessage());
// TODO: 2020-09-07 construct original payload with column valu like SQL describe command output
erroneousEvent.setOriginalPayload(addingEventChunk.toString());
ErrorStoreHelper.storeErroneousEvent(siddhiAppContext.getSiddhiContext().getErrorStore(),
