xiaolong-sn commented on a change in pull request #13015:
URL: https://github.com/apache/flink/pull/13015#discussion_r503000484
##########
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
##########
@@ -44,13 +51,18 @@
@Internal
public class KinesisConfigUtil {
- /** Maximum number of items to pack into an PutRecords request. **/
+ /**
+ * Maximum number of items to pack into an PutRecords request.
+ **/
protected static final String COLLECTION_MAX_COUNT =
"CollectionMaxCount";
- /** Maximum number of items to pack into an aggregated record. **/
+ /**
+ * Maximum number of items to pack into an aggregated record.
+ **/
Review comment:
Thanks!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
