This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch fix-timestamp-extraction in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 76b7281b5f28f8480c2f104bca25e9a5d25a2f0f Author: Dominik Riemer <[email protected]> AuthorDate: Wed Jul 16 13:08:52 2025 +0200 fix: Extract timestamp in data download query --- .../java/org/apache/streampipes/model/datalake/DataLakeMeasure.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java index a7029fa520..61895df80d 100644 --- a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java +++ b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java @@ -147,7 +147,8 @@ public class DataLakeMeasure implements Storable { @TsIgnore @JsonIgnore public String getTimestampFieldName() { - return timestampField.split(STREAM_PREFIX_DELIMITER)[1]; + var timestampWithPrefix = timestampField.split(STREAM_PREFIX_DELIMITER); + return timestampWithPrefix.length > 1 ? timestampWithPrefix[1] : timestampField; } @Override
