diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/table/holder/IndexEventHolderForCache.java b/modules/siddhi-core/src/main/java/io/siddhi/core/table/holder/IndexEventHolderForCache.java index 7f6f178db4..e7f14517a8 100644 --- a/modules/siddhi-core/src/main/java/io/siddhi/core/table/holder/IndexEventHolderForCache.java +++ b/modules/siddhi-core/src/main/java/io/siddhi/core/table/holder/IndexEventHolderForCache.java @@ -1,5 +1,5 @@ /* - * Copyright (c) 2017, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. + * Copyright (c) 2019, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. * * WSO2 Inc. licenses this file to you under the Apache License, * Version 2.0 (the "License"); you may not use this file except diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/util/collection/operator/OverwriteTableIndexOperatorForCache.java b/modules/siddhi-core/src/main/java/io/siddhi/core/util/collection/operator/OverwriteTableIndexOperatorForCache.java index 40c2f1cd2c..0a210721f8 100644 --- a/modules/siddhi-core/src/main/java/io/siddhi/core/util/collection/operator/OverwriteTableIndexOperatorForCache.java +++ b/modules/siddhi-core/src/main/java/io/siddhi/core/util/collection/operator/OverwriteTableIndexOperatorForCache.java @@ -40,13 +40,11 @@ public ComplexEventChunk tryUpdate(ComplexEventChunk upd Object storeEvents, InMemoryCompiledUpdateSet compiledUpdateSet, AddingStreamEventExtractor addingStreamEventExtractor) { - updatingOrAddingEventChunk.reset(); while (updatingOrAddingEventChunk.hasNext()) { StateEvent overwritingOrAddingEvent = updatingOrAddingEventChunk.next(); ((IndexedEventHolder) storeEvents).overwrite(addingStreamEventExtractor.getAddingStreamEvent (overwritingOrAddingEvent)); - } return null; }