You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2020/12/03 08:05:24 UTC
[flink] branch master updated (b31495f -> 208126a)
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b31495f [FLINK-19527][Doc]Flink SQL Getting Started
add d786c10 [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.
add 208126a Revert "[FLINK-14076] Ensure CheckpointException can be deserialized on JobManager"
No new revisions were added by this update.
Summary of changes:
.../connectors/cassandra/CassandraSinkBaseTest.java | 5 +----
.../connectors/kafka/FlinkKafkaProducerITCase.java | 6 +++---
.../flink/runtime/checkpoint/CheckpointException.java | 13 ++-----------
.../runtime/messages/checkpoint/DeclineCheckpoint.java | 18 ++++++++----------
.../functions/sink/TwoPhaseCommitSinkFunctionTest.java | 3 +--
5 files changed, 15 insertions(+), 30 deletions(-)