Skip to content

Commit 2a44f3f

Browse files
committed
[elasticsearch-xh][sink]remove check.
1 parent 2728f89 commit 2a44f3f

File tree

2 files changed

+0
-11
lines changed

2 files changed

+0
-11
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,6 @@ public ExtendES5ApiCallBridge(List<InetSocketAddress> transportAddresses, Elasti
6666
Preconditions.checkArgument(transportAddresses != null && !transportAddresses.isEmpty());
6767
this.transportAddresses = transportAddresses;
6868
this.esTableInfo = esTableInfo;
69-
this.esTableInfo.judgeKrbEnable();
7069
}
7170

7271
@Override

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

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -160,16 +160,6 @@ public boolean check() {
160160
Preconditions.checkArgument(NumberUtils.isNumber(number), "id must be a numeric type");
161161
});
162162
}
163-
164-
165-
// all or nothing
166-
boolean allSet = Strings.isNullOrEmpty(principal)
167-
== Strings.isNullOrEmpty(keytab)
168-
== Strings.isNullOrEmpty(krb5conf);
169-
170-
171-
Preconditions.checkState(!allSet, "xh's elasticsearch type of kerberos file is required");
172-
173163
return true;
174164
}
175165

0 commit comments

Comments
 (0)