CrynetLogistics commented on a change in pull request #18553:
URL: https://github.com/apache/flink/pull/18553#discussion_r795529758
##########
File path:
flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsException.java
##########
@@ -39,12 +39,12 @@ public KinesisDataStreamsException(final String message,
final Throwable cause)
public KinesisDataStreamsFailFastException() {
super(
- "Encountered an exception while persisting records, not
retrying due to {failOnError} being set.");
+ "Encountered an exception while persisting records, not
retrying due to either: {failOnError} being set or the exception should not be
retried.");
}
public KinesisDataStreamsFailFastException(final Throwable cause) {
super(
- "Encountered an exception while persisting records, not
retrying due to {failOnError} being set.",
+ "Encountered an exception while persisting records, not
retrying due to either: {failOnError} being set or the exception should not be
retried.",
Review comment:
Ah nevermind, I understand now.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
