| commit | 21d3b10e4d66aca82d70a05a4ab24fb5cf2db348 | [log] [tgz] |
|---|---|---|
| author | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Tue Jul 04 13:17:19 2023 +0800 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Wed Jul 12 20:42:39 2023 +0800 |
| tree | 47c62873ea8126b726676b3eae3fbd6ed57d9cc0 | |
| parent | 97dbfcadee982eaae3800f478cf6ba857de1b2db [diff] |
[FLINK-32453] Ambiguous assertThat call after upgrade to Flink 1.18 This closes #39.
diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java index 3ced33f..b89f1b1 100644 --- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java +++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java
@@ -404,7 +404,7 @@ assertThat(adminClient).isNotNull(); String clientId = (String) Whitebox.getInternalState(adminClient, "clientId"); assertThat(clientId).isNotNull().startsWith(clientIdPrefix); - assertThat(Whitebox.getInternalState(adminClient, "defaultApiTimeoutMs")) + assertThat((int) Whitebox.getInternalState(adminClient, "defaultApiTimeoutMs")) .isEqualTo(defaultTimeoutMs); assertThat(clientId).isNotNull().startsWith(clientIdPrefix);