Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3992#discussion_r118726185
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
---
@@ -105,7 +105,7 @@ public RMQSource(RMQConnectionConfig
rmqConnectionConfig, String queueName,
/**
* Creates a new RabbitMQ source. For exactly-once, you must set the
correlation ids of messages
* at the producer. The correlation id must be unique. Otherwise the
behavior of the source is
- * undefined. In doubt, set {@param usesCorrelationId} to false. When
correlation ids are not
+ * undefined. In doubt, set usesCorrelationId to false. When
correlation ids are not
--- End diff --
"If in doubt"?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
