(streampipes) branch dev updated: Migrate DataStream Name in existing Pipelines when updating an Adapter (#3947)

[zehnder]

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

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 6592de3773 Migrate DataStream Name in existing Pipelines when updating 
an Adapter (#3947)
6592de3773 is described below

commit 6592de37738558727aff02325df72bc182c44bb7
Author: Jacqueline Höllig <78690944+jhoe...@users.noreply.github.com>
AuthorDate: Thu Nov 20 15:10:07 2025 +0100

    Migrate DataStream Name in existing Pipelines when updating an Adapter 
(#3947)
---
 .../connect/management/management/AdapterUpdateManagement.java         | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
index 350c71609a..963e9e1677 100644
--- 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
+++ 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
@@ -60,7 +60,7 @@ public class AdapterUpdateManagement {
 
   public void updateAdapter(AdapterDescription ad)
       throws AdapterException {
-    // update adapter in database
+    // update adapter in database 
     this.adapterResourceManager.encryptAndUpdate(ad);
     boolean shouldRestart = ad.isRunning();
 
@@ -187,6 +187,7 @@ public class AdapterUpdateManagement {
         .peek(s -> {
           if 
(s.getElementId().equals(updatedAdapter.getCorrespondingDataStreamElementId())) 
{
             s.setEventSchema(updatedAdapter.getEventSchema());
+            s.setName(updatedAdapter.getName());
           }
         })
         .toList();