This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
3257-streampipesfunctionhandler-does-not-clean-up-all-functions-on-service-stop
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/3257-streampipesfunctionhandler-does-not-clean-up-all-functions-on-service-stop
by this push:
new 3878a81be8 fix(#3257): Synchronously trigger deregistration handler
3878a81be8 is described below
commit 3878a81be8f9278157b503a84dce62d5bdc6e545
Author: Philipp Zehnder <[email protected]>
AuthorDate: Thu Sep 26 16:37:05 2024 +0200
fix(#3257): Synchronously trigger deregistration handler
---
.../service/extensions/function/StreamPipesFunctionHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
b/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
index 7b02dc4db4..a36d788a4d 100644
---
a/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
+++
b/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
@@ -96,7 +96,7 @@ public enum StreamPipesFunctionHandler {
this.runningInstances.forEach((key, value) -> {
value.discardRuntime();
});
- new Thread(new
FunctionDeregistrationHandler(getFunctionDefinitions())).start();
+ new FunctionDeregistrationHandler(getFunctionDefinitions()).run();
}
private List<FunctionDefinition> getFunctionDefinitions() {
