diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java index c5fec30214aa6d1d197b86678903894c5e89189c..e964baf803b6d540e52e126c5d54537cf81ee712 100644 --- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java +++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java @@ -34,10 +34,10 @@ import org.influxdb.dto.QueryResult; import org.influxdb.querybuilder.SelectQueryImpl; import org.influxdb.querybuilder.WhereQueryImpl; +import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.contains; import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.eq; import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.gte; import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.lte; -import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.regex; import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.select; @Slf4j @@ -64,7 +64,7 @@ public class AlarmQuery implements IAlarmQueryDAO { .and(lte(InfluxClient.TIME, InfluxClient.timeInterval(endTB))); } if (!Strings.isNullOrEmpty(keyword)) { - recallQuery.and(regex(AlarmRecord.ALARM_MESSAGE, keyword)); + recallQuery.and(contains(AlarmRecord.ALARM_MESSAGE, keyword.replaceAll("/", "\\\\/"))); } if (Objects.nonNull(scopeId)) { recallQuery.and(eq(AlarmRecord.SCOPE, scopeId));