This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1702c9e Revert "[FLINK-24041][connectors] Added unit and integration
tests for the generic sink implementation. Corrected an inconsistency that led
to prepareCommit() not fully flushing the entire contents of the buffer at
checkpoint time, removed catching of RuntimeExceptions in concrete
implementations, added @PublicEvolving to classes, rearranged cosmetics of
classes, corrected spelling errors, changed tests to reflect removal of
RuntimeException, added checks on the paramete [...]
add 16ab8b4 Revert "[FLINK-24041][connectors] First draft of API, Add
DynamoDB sink to verify API, Add Firehose sink, Refactor to use FLIP-143:
Unified Sink API, Increase robustness for flush, Add license header, Update
JavaDoc comments"
No new revisions were added by this update.
Summary of changes:
.../flink/connector/base/sink/AsyncSinkBase.java | 79 --------
.../base/sink/writer/AsyncSinkWriter.java | 216 ---------------------
.../base/sink/writer/ElementConverter.java | 34 ----
.../connector/base/sink/writer/ResultFuture.java | 29 ---
.../src/main/resources/log4j2.properties | 25 ---
.../flink-connector-kinesis-171/pom.xml | 149 --------------
.../connectors/AmazonKinesisDataStreamSink.java | 131 -------------
.../software/amazon/flink/connectors/Test.java | 71 -------
flink-connectors/pom.xml | 1 -
9 files changed, 735 deletions(-)
delete mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java
delete mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
delete mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/ElementConverter.java
delete mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/ResultFuture.java
delete mode 100644
flink-connectors/flink-connector-base/src/main/resources/log4j2.properties
delete mode 100644 flink-connectors/flink-connector-kinesis-171/pom.xml
delete mode 100644
flink-connectors/flink-connector-kinesis-171/src/main/java/software/amazon/flink/connectors/AmazonKinesisDataStreamSink.java
delete mode 100644
flink-connectors/flink-connector-kinesis-171/src/main/java/software/amazon/flink/connectors/Test.java
