You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2025/06/13 09:21:12 UTC
(streampipes) branch 3672-nightly-build-fails-due-to-pipeline-element-tests updated: fix(#3672): Fix null pointer when property scope is not set properly
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch 3672-nightly-build-fails-due-to-pipeline-element-tests
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/3672-nightly-build-fails-due-to-pipeline-element-tests by this push:
new fee98fa6a1 fix(#3672): Fix null pointer when property scope is not set properly
fee98fa6a1 is described below
commit fee98fa6a13d19373035fc3b20dfa4696a3429a7
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Fri Jun 13 11:21:03 2025 +0200
fix(#3672): Fix null pointer when property scope is not set properly
---
.../apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java
index c2b361406b..306327cca8 100644
--- a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java
+++ b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java
@@ -172,8 +172,8 @@ public class DataLakeSink extends StreamPipesDataSink implements SupportsRuntime
})
.peek(ep -> {
// Remova all dimensions from DIMENSION_PROPERTY scope if not part of dimensions
- if (ep.getPropertyScope()
- .equals(PropertyScope.DIMENSION_PROPERTY.name())) {
+ if (PropertyScope.DIMENSION_PROPERTY.name()
+ .equals(ep.getPropertyScope())) {
if (!dimensions.contains(ep.getRuntimeName())) {
ep.setPropertyScope(PropertyScope.MEASUREMENT_PROPERTY.name());
}