diff --git a/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 b/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 index 0a4a561..d3fbf24 100644 --- a/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 +++ b/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 @@ -52,12 +52,12 @@ processing_pipelines: lookup_fields: [ client_country ] - function: FIRST_VALUE lookup_fields: [ server_country ] - - function: NUMBER_MIN + - function: MIN lookup_fields: [ timestamp_ms ] output_fields: [ start_timestamp_ms ] - - function: NUMBER_MIN + - function: MIN lookup_fields: [ recv_time ] - - function: NUMBER_MAX + - function: MAX lookup_fields: [ timestamp_ms ] output_fields: [ end_timestamp_ms ] - function: FIRST_VALUE diff --git a/tsg_olap/installation/flink/groot_stream/udf.plugins b/tsg_olap/installation/flink/groot_stream/udf.plugins index 49edca1..1913883 100644 --- a/tsg_olap/installation/flink/groot_stream/udf.plugins +++ b/tsg_olap/installation/flink/groot_stream/udf.plugins @@ -33,5 +33,5 @@ com.geedgenetworks.core.udf.udtf.PathUnroll com.geedgenetworks.core.udf.uuid.Uuid com.geedgenetworks.core.udf.uuid.UuidV5 com.geedgenetworks.core.udf.uuid.UuidV7 -com.geedgenetworks.core.udf.udaf.NumberMax -com.geedgenetworks.core.udf.udaf.NumberMin \ No newline at end of file +com.geedgenetworks.core.udf.udaf.Max +com.geedgenetworks.core.udf.udaf.Min \ No newline at end of file diff --git a/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 b/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 index 0a4a561..d3fbf24 100644 --- a/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 +++ b/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 @@ -52,12 +52,12 @@ processing_pipelines: lookup_fields: [ client_country ] - function: FIRST_VALUE lookup_fields: [ server_country ] - - function: NUMBER_MIN + - function: MIN lookup_fields: [ timestamp_ms ] output_fields: [ start_timestamp_ms ] - - function: NUMBER_MIN + - function: MIN lookup_fields: [ recv_time ] - - function: NUMBER_MAX + - function: MAX lookup_fields: [ timestamp_ms ] output_fields: [ end_timestamp_ms ] - function: FIRST_VALUE diff --git a/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins b/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins index 49edca1..1913883 100644 --- a/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins +++ b/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins @@ -33,5 +33,5 @@ com.geedgenetworks.core.udf.udtf.PathUnroll com.geedgenetworks.core.udf.uuid.Uuid com.geedgenetworks.core.udf.uuid.UuidV5 com.geedgenetworks.core.udf.uuid.UuidV7 -com.geedgenetworks.core.udf.udaf.NumberMax -com.geedgenetworks.core.udf.udaf.NumberMin \ No newline at end of file +com.geedgenetworks.core.udf.udaf.Max +com.geedgenetworks.core.udf.udaf.Min \ No newline at end of file