This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 291f920 [MINOR] Fix wrong logic for checking state condition (#2524)
291f920 is described below
commit 291f92069eee7bbff5e192d7ea6576a25a8c400c
Author: ZhangChaoMing <[email protected]>
AuthorDate: Sat Feb 6 16:40:31 2021 +0800
[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 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 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"));
}
}