From 291f92069eee7bbff5e192d7ea6576a25a8c400c Mon Sep 17 00:00:00 2001
From: ZhangChaoMing <72908278+ZhangChaoming@users.noreply.github.com>
Date: Sat, 6 Feb 2021 16:40:31 +0800
Subject: [PATCH] [MINOR] Fix wrong logic for checking state condition (#2524)

---
 hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java b/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
index 9460ee89e..2fa87575d 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -248,6 +248,6 @@ public class StreamerUtil {
 
   public static void checkRequiredProperties(TypedProperties props, List<String> checkPropNames) {
     checkPropNames.forEach(prop ->
-        Preconditions.checkState(!props.containsKey(prop), "Required property " + prop + " is missing"));
+        Preconditions.checkState(props.containsKey(prop), "Required property " + prop + " is missing"));
   }
 }