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 c221ada4d0 fix StatelessTransformationRuleGeneratorVisitor set rule
mode (#2846)
c221ada4d0 is described below
commit c221ada4d09651ee0ee97c5cbfc760f014346c15
Author: yanfeng1992 <[email protected]>
AuthorDate: Mon May 13 14:05:41 2024 +0800
fix StatelessTransformationRuleGeneratorVisitor set rule mode (#2846)
Signed-off-by: huangyanfeng <[email protected]>
---
.../generator/StatelessTransformationRuleGeneratorVisitor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
b/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
index 7adf1b3765..1728d8db27 100644
---
a/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
+++
b/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
@@ -117,7 +117,7 @@ public class StatelessTransformationRuleGeneratorVisitor
extends TransformationR
if
(ruleDesc.getMode().equals(TimestampTranformationRuleMode.FORMAT_STRING.internalName()))
{
mode = TimestampTranformationRuleMode.FORMAT_STRING;
} else {
- mode = TimestampTranformationRuleMode.FORMAT_STRING;
+ mode = TimestampTranformationRuleMode.TIME_UNIT;
}
rules.add(new TimestampTransformationRule(Utils.toKeyArray(
