This is an automated email from the ASF dual-hosted git repository.
libenchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 4db3680 Fix typo in KafkaResource (#12564)
4db3680 is described below
commit 4db368035f00ef7b990a86f1285921e9834e4f6c
Author: Da(Dash)Shen <[email protected]>
AuthorDate: Wed Jun 10 11:23:52 2020 +0800
Fix typo in KafkaResource (#12564)
This closes #12564
---
.../src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java
index 0157ad2..bd5ba46 100644
---
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java
+++
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java
@@ -102,7 +102,7 @@ public interface KafkaResource extends ExternalResource {
/**
* Returns the configured KafkaResource implementation, or a {@link
LocalStandaloneKafkaResource} if none is configured.
*
- * @return configured KafkaResource, or {@link
LocalStandaloneKafkaResource} is none is configured
+ * @return configured KafkaResource, or {@link
LocalStandaloneKafkaResource} if none is configured
*/
static KafkaResource get(final String version) {
return FactoryUtils.loadAndInvokeFactory(