[incubator-streampipes] 02/04: introduced policy reset after successful offloading

[gomm]

This is an automated email from the ASF dual-hosted git repository.

gomm pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit d2bfbd106e4dd1bce144c246f8b75630b7af54ac
Author: daniel-gomm <daniel.g...@outlook.de>
AuthorDate: Fri Oct 8 09:41:28 2021 +0200

    introduced policy reset after successful offloading
---
 .../node/controller/management/offloading/OffloadingPolicyManager.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/OffloadingPolicyManager.java
 
b/streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/OffloadingPolicyManager.java
index 73ae24e..5d745ce 100644
--- 
a/streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/OffloadingPolicyManager.java
+++ 
b/streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/OffloadingPolicyManager.java
@@ -93,6 +93,7 @@ public class OffloadingPolicyManager {
 
             if(resp.isSuccess()){
                 LOG.info("Successfully offloaded: {} of pipeline: {}", appId, 
pipelineName);
+                strategy.getOffloadingPolicy().reset();
             } else{
                 LOG.warn("Failed to offload: {} of pipeline: {}", appId, 
pipelineName);
                 unsuccessfullyTriedEntities.add(offloadEntity);