Commits

Commits on Dec 9, 2021

[FLINK-23170][state] add unit test for Timer Restore for different statebackends
curcur
committedDec 9, 2021
[hotfix] Change ChangelogStateBackendTestUtils#testMaterializedRestore to single thread
curcur
committedDec 9, 2021
[FLINK-23170][state] write metadata after materialization
curcur
committedDec 9, 2021

Commits on Oct 25, 2021

[FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints (apache#16606 )
curcur
committedOct 25, 2021

Commits on Sep 9, 2021

[FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (apache#17173 )
curcur
committedSep 9, 2021

Commits on Aug 13, 2021

[FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish (apache#16768 )
curcur
committedAug 13, 2021

Commits on Jul 22, 2021

[FLINK-23204] Provide StateBackends access to MailboxExecutor (apache#16531 )
curcur
committedJul 22, 2021

Commits on Jul 6, 2021

[FLINK-21448] Randomize ITTests

curcur
authored and
rkhachatryan
committedJul 6, 2021

Commits on May 12, 2021

[FLINK-21469][runtime] Implement advanceToEndOfEventTime for MultipleInputStreamTask

curcur
authored and
dawidwys
committedMay 12, 2021

Commits on Apr 27, 2021

[FLINK-22289] Update JDBC XA sink docs

curcur
authored and
rkhachatryan
committedApr 27, 2021

Commits on Apr 14, 2021

[FLINK-21839][docs] Document stop-with-savepoint behavior more explicitly

curcur
authored and
dawidwys
committedApr 14, 2021
[FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

curcur
authored and
rkhachatryan
committedApr 14, 2021

Commits on Apr 9, 2021

[hotfix] Remove unnessary rollbackPreparedFromCheckpoint from JdbcXaSinkFunction.snapshot

curcur
authored and
rkhachatryan
committedApr 9, 2021
[hotfix] Fix the release version for JdbcXaSinkFunction

curcur
authored and
rkhachatryan
committedApr 9, 2021

Commits on Mar 21, 2021

[hotfix][state backend] Put the delegating log to ChangelogStateBackend constructor

curcur
authored and
rkhachatryan
committedMar 21, 2021

Commits on Mar 15, 2021

[FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur
authored and
rkhachatryan
committedMar 15, 2021

Commits on Jan 25, 2021

[FLINK-21018] Update checkpoint related documentation for UI

curcur
authored and
pnowojski
committedJan 25, 2021

Commits on Jan 12, 2021

[FLINK-20453][runtime][checkpoint] Move checkpointing classes to an appropriate package

curcur
authored and
pnowojski
committedJan 12, 2021

Commits on Jan 8, 2021

[FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI (AC/UC) for each subtask

curcur
authored and
pnowojski
committedJan 8, 2021

Commits on Jan 4, 2021

[docs/javadoc][hotfix] Explicitly Document task cancellation timeout does not apply to task failure

curcur
authored and
pnowojski
committedJan 4, 2021

Commits on Nov 8, 2020

[FLINK-19693] ITCases for Approximate Local Recovery

curcur
authored and
tillrohrmann
committedNov 8, 2020
[FLINK-19693] Introduce a flag to enable approximate failover

curcur
authored and
tillrohrmann
committedNov 8, 2020
[FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur
authored and
tillrohrmann
committedNov 8, 2020

Commits on Nov 5, 2020

[hotfix] Do not emit EndOfChannelRecoveryEvent for Approximate Local Recovery

curcur
authored and
AHeise
committedNov 5, 2020

Commits on Nov 2, 2020

[FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur
authored and
AHeise
committedNov 2, 2020

Commits on Oct 27, 2020

[hotfix][runtime] Rename XXXSubPartitionBufferBuilderXXX to XXXUnicastBufferBuilderXXX

curcur
authored and
pnowojski
committedOct 27, 2020
[FLINK-19547][Runtime] Update BufferConsumer with BufferConsumerWithPartialRecordLength in PipelinedSubpartition.java

curcur
authored and
pnowojski
committedOct 27, 2020
[FLINK-19547][Runtime] Add the partialRecordLength when creating a BufferConsumer

curcur
authored and
pnowojski
committedOct 27, 2020

Commits on Aug 24, 2020

[FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

curcur
authored and
pnowojski
committedAug 24, 2020

Commits on Jul 8, 2020

[FLINK-15414] catch the right KafkaException for binding errors

curcur
authored and
dawidwys
committedJul 8, 2020

Commits on Jun 22, 2020

[FLINK-17769] Wrong order of log events on a task failure

curcur
authored and
pnowojski
committedJun 22, 2020

Commits on May 27, 2020

[FLINK-17351] Increase continuousFailureCounter in CheckpointFailureManager for CHECKPOINT_EXPIRED

curcur
authored and
pnowojski
committedMay 27, 2020

Commits on May 18, 2020

[FLINK-15670] Kafka Shuffle Test Case + add log4j2 file

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][connector] Kafka Shuffle API Part

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][connector] Adds the consumer for KafkaShuffle.

curcur
authored and
pnowojski
committedMay 18, 2020