(flink-connector-cassandra) branch main updated: [hotfix] Updated CQL_PROHIBITED_CLAUSES_REGEXP to match the "ORDER BY" keyword instead of just "ORDER"

[ec...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git


The following commit(s) were added to refs/heads/main by this push:
     new 20c5f50  [hotfix] Updated CQL_PROHIBITED_CLAUSES_REGEXP to match the "ORDER BY" keyword instead of just "ORDER"
20c5f50 is described below

commit 20c5f50721339db871127eea08264bd3e1a43575
Author: Nathan <na...@gmail.com>
AuthorDate: Mon Nov 20 11:34:52 2023 +0100

    [hotfix] Updated CQL_PROHIBITED_CLAUSES_REGEXP to match the "ORDER BY" keyword instead of just "ORDER"
---
 .../org/apache/flink/connector/cassandra/source/CassandraSource.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java b/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java
index 6ac90d0..b9b6d0f 100644
--- a/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java
+++ b/flink-connector-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+).*;$");