Skip to content

Commit 2781eef

Browse files
committed
[Improve] Prevent SQL injection
1 parent 2d0d79f commit 2781eef

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ApplicationBackUpCleanTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void backUpClean() {
4343
backUpService.lambdaQuery()
4444
.select(FlinkApplicationBackup::getAppId)
4545
.groupBy(FlinkApplicationBackup::getAppId)
46-
.having("count(*) > " + maxBackupNum)
46+
.having("COUNT(*) > {0}", maxBackupNum)
4747
.list()
4848
.stream()
4949
.map(FlinkApplicationBackup::getAppId)

0 commit comments

Comments
 (0)