Skip to content

Commit 88984ff

Browse files
committed
[hotfix-36517][elasticsearch-xh][sink]fix bug which can not found kerberos files.
1 parent ce250fb commit 88984ff

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchTableInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ public boolean check() {
166166
Strings.isNullOrEmpty(keytab) &&
167167
Strings.isNullOrEmpty(krb5conf);
168168

169-
Preconditions.checkState(allNotSet, "xh's elasticsearch type of kerberos file is required");
169+
Preconditions.checkState(!allNotSet, "xh's elasticsearch type of kerberos file is required");
170170

171171
return true;
172172
}

0 commit comments

Comments
 (0)