(streampipes) branch change-data-stream-update-event-to-only-publish-schema-changes updated: Simplify data stream schema update event

[oehler]

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

SvenO3 pushed a commit to branch 
change-data-stream-update-event-to-only-publish-schema-changes
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/change-data-stream-update-event-to-only-publish-schema-changes by 
this push:
     new bf4b76714a Simplify data stream schema update event
bf4b76714a is described below

commit bf4b76714a82cf74a7762f96054290f71ed9c317
Author: Sven Oehler <oehler.s...@web.de>
AuthorDate: Fri Oct 30 10:28:56 2026 +0100

    Simplify data stream schema update event
---
 .../manager/pipeline/update/DataStreamSchemaUpdatedEvent.java         | 4 +---
 .../manager/pipeline/update/DataStreamUpdateManagement.java           | 2 +-
 .../manager/pipeline/update/DataStreamUpdateManagementTest.java       | 2 +-
 3 files changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamSchemaUpdatedEvent.java
 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamSchemaUpdatedEvent.java
index 07d74c2f27..abdf023a75 100644
--- 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamSchemaUpdatedEvent.java
+++ 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamSchemaUpdatedEvent.java
@@ -18,7 +18,5 @@
 
 package org.apache.streampipes.manager.pipeline.update;
 
-import org.apache.streampipes.model.SpDataStream;
-
-public record DataStreamSchemaUpdatedEvent(SpDataStream dataStream) {
+public record DataStreamSchemaUpdatedEvent(String elementId, String name) {
 }
diff --git 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagement.java
 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagement.java
index 94cf953827..5de6578114 100644
--- 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagement.java
+++ 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagement.java
@@ -50,7 +50,7 @@ public class DataStreamUpdateManagement {
     dataStreamResourceManager.update(dataStream);
     pipelineUpdateCoordinator.updatePipelines(dataStream);
     if (schemaChanged) {
-      eventPublisher.publishEvent(new 
DataStreamSchemaUpdatedEvent(dataStream));
+      eventPublisher.publishEvent(new 
DataStreamSchemaUpdatedEvent(dataStream.getElementId(), dataStream.getName()));
     }
   }
 
diff --git 
a/streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagementTest.java
 
b/streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagementTest.java
index 6fa5daf027..97e16c7f0e 100644
--- 
a/streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagementTest.java
+++ 
b/streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/update/DataStreamUpdateManagementTest.java
@@ -56,7 +56,7 @@ class DataStreamUpdateManagementTest {
       order.verify(streams).find("stream-1");
       order.verify(streams).update(updated);
       
order.verify(coordinators.constructed().getFirst()).updatePipelines(updated);
-      order.verify(publisher).publishEvent(new 
DataStreamSchemaUpdatedEvent(updated));
+      order.verify(publisher).publishEvent(new 
DataStreamSchemaUpdatedEvent(updated.getElementId(), updated.getName()));
     }
   }