[clickhouse] classify ErrQueryProhibited (#3526)

heavycrystal · web-flow · commit adf31a3be9fc · 2025-09-26T17:21:38.000+05:30
diff --git a/flow/alerting/classifier.go b/flow/alerting/classifier.go
@@ -626,6 +626,10 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {
 			if strings.HasSuffix(chException.Message, "distributed_ddl_task_timeout") {
 				return ErrorRetryRecoverable, chErrorInfo
 			}
+		case chproto.ErrQueryIsProhibited:
+			if strings.Contains(chException.Message, "Replicated DDL queries are disabled") {
+				return ErrorRetryRecoverable, chErrorInfo
+			}
 		}
 		var normalizationErr *exceptions.NormalizationError
 		if isClickHouseMvError(chException) {

Original file line number	Diff line number	Diff line change
`@@ -626,6 +626,10 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {`
`626`	`626`	`if strings.HasSuffix(chException.Message, "distributed_ddl_task_timeout") {`
`627`	`627`	`return ErrorRetryRecoverable, chErrorInfo`
`628`	`628`	`}`
	`629`	`+ case chproto.ErrQueryIsProhibited:`
	`630`	`+ if strings.Contains(chException.Message, "Replicated DDL queries are disabled") {`
	`631`	`+ return ErrorRetryRecoverable, chErrorInfo`
	`632`	`+ }`
`629`	`633`	`}`
`630`	`634`	`var normalizationErr *exceptions.NormalizationError`
`631`	`635`	`if isClickHouseMvError(chException) {`