This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8cdd0b85 [FLINK-26252][tests] Refactor MiniClusterExtension to support
JUnit 5 parallel tests
add 786fc55 [FLINK-25846][connector/kinesis] Fixing stuck at Cancelling
on failed requests
add 8d75a6c [FLINK-25848][connectors/kinesis] KDS Sink failing fast when
bad credentials are provided.
add ec83c08 [FLINK-25848][connectors/firehose] Separated unit style tests
for the KDF Sink into KinesisFirehoseSinkTest
No new revisions were added by this update.
Summary of changes:
.../aws/util/AWSAuthenticationException.java | 22 +-
.../AWSCredentialFatalExceptionClassifiers.java | 43 ++++
.../flink/connector/aws/util/AWSGeneralUtil.java | 45 ++--
.../connector/aws/util/AWSGeneralUtilTest.java | 45 ++++
.../kinesis/sink/KinesisDataStreamsException.java | 10 +-
.../kinesis/sink/KinesisDataStreamsSinkWriter.java | 31 ++-
.../kinesis/sink/KinesisDataStreamsSinkITCase.java | 259 ++++++++++++++++++---
.../firehose/sink/KinesisFirehoseException.java | 10 +-
.../firehose/sink/KinesisFirehoseSinkWriter.java | 29 ++-
.../firehose/sink/KinesisFirehoseSinkITCase.java | 41 ++--
.../firehose/sink/KinesisFirehoseSinkTest.java | 56 +++++
.../sink/KinesisFirehoseSinkWriterTest.java | 11 +-
.../sink/testutils/KinesisFirehoseTestUtils.java | 30 ++-
.../sink/throwable/FatalExceptionClassifier.java | 86 +++++++
.../writer/AsyncSinkFatalExceptionClassifiers.java | 19 +-
.../throwable/FatalExceptionClassifierTest.java | 138 +++++++++++
.../table/test/KinesisFirehoseTableITTest.java | 4 +-
17 files changed, 754 insertions(+), 125 deletions(-)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/SqlParserException.java
=>
flink-connectors/flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSAuthenticationException.java
(62%)
create mode 100644
flink-connectors/flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSCredentialFatalExceptionClassifiers.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/throwable/FatalExceptionClassifier.java
copy
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/exceptions/UnknownLocationException.java
=>
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkFatalExceptionClassifiers.java
(64%)
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/throwable/FatalExceptionClassifierTest.java
