diff --git a/pom.xml b/pom.xml
index a85f062..8efea7c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -33,7 +33,7 @@ under the License.
 		<maven.compiler.target>${target.java.version}</maven.compiler.target>
 		<target.java.version>24</target.java.version>
 		<scala.binary.version>2.12</scala.binary.version>
-		<flink.version>2.0.0</flink.version>
+		<flink.version>2.1.0</flink.version>
 		<log4j.version>2.24.1</log4j.version>
 		<web3j.version>5.0.0</web3j.version>
 		<httpclient5.version>5.3.1</httpclient5.version>
@@ -73,6 +73,14 @@ under the License.
 			<scope>provided</scope>
 -->
 		</dependency>
+		<dependency>
+			<groupId>org.apache.flink</groupId>
+			<artifactId>flink-cep</artifactId>
+			<version>${flink.version}</version>
+<!--
+			<scope>provided</scope>
+-->
+		</dependency>
 
 		<!-- Add connector dependencies here. They must be in the default scope (compile). -->