commit 291f92069eee7bbff5e192d7ea6576a25a8c400c
author ZhangChaoMing <72908278+ZhangChaoming@users.noreply.github.com> Sat Feb 06 16:40:31 2021 +0800
committer GitHub <noreply@github.com> Sat Feb 06 16:40:31 2021 +0800
tree f49cf1d151b60e908ff62420c11381c6ff35a0a0
parent b2c47a24be53016d1c9220cb98d9fb7cd587e748

[MINOR] Fix wrong logic for checking state condition (#2524)

hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java

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 9460ee8..2fa8757 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 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"));
   }
 }