[hotfix] Updated CQL_PROHIBITED_CLAUSES_REGEXP to match the "ORDER BY…

…" keyword instead of just "ORDER"
apache · Nov 21, 2023 · 20c5f50 · 20c5f50
1 parent b95690f
commit 20c5f50
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java b/...-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java
@@ -90,7 +90,7 @@ public class CassandraSource<OUT>
         implements Source<OUT, CassandraSplit, CassandraEnumeratorState>, ResultTypeQueryable<OUT> {
 
     public static final Pattern CQL_PROHIBITED_CLAUSES_REGEXP =
-            Pattern.compile("(?i).*(AVG|COUNT|MIN|MAX|SUM|ORDER|GROUP BY).*");
+            Pattern.compile("(?i).*(AVG|COUNT|MIN|MAX|SUM|ORDER BY|GROUP BY).*");
     public static final Pattern SELECT_REGEXP =
             Pattern.compile("(?i)select .+ from (\\w+)\\.(\\w+).*;$");