Merge pull request #1755 from dilini-muthumala/master

Fix reconnecting for Error Store
siddhi-io · Nov 5, 2021 · a3c9c6b · a3c9c6b
2 parents 5626bc5 + 801536d
commit a3c9c6b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/Sink.java b/modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/Sink.java
@@ -435,6 +435,7 @@ public void onError(Object payload, DynamicOptions dynamicOptions, Exception e)
                     }
                     break;
                 case STORE:
+                    connectWithRetry();
                     ErroneousEvent erroneousEvent = new ErroneousEvent(dynamicOptions.getEvent(), e, e.getMessage());
                     erroneousEvent.setOriginalPayload(payload);
                     ErrorStoreHelper.storeErroneousEvent(siddhiAppContext.getSiddhiContext().getErrorStore(),