Commits

History for

Commits on May 15, 2020

[FLINK-17218][tests] Adding recoverable failures and correctness checks to UnalignedCheckpointITCase.

Arvid Heise
authored and
pnowojski
committedMay 15, 2020

Commits on May 14, 2020

[FLINK-14807][rest] Introduce REST API for communication between clients and operator coordinators
tsreaper
committedMay 14, 2020
[FLINK-17578] In StreamEdge, use output tag in hashCode and equals

damjad
authored and
aljoscha
committedMay 14, 2020

Commits on May 13, 2020

[FLINK-11086] Clean up profiles and dependency exclusions
rmetzger
committedMay 13, 2020
[FLINK-11086] Replace flink-shaded-hadoop-2 dependency by vanilla Hadoop dependency
rmetzger
committedMay 13, 2020
[FLINK-17476][tests] test recovery from snapshot created in different UC mode

rkhachatryan
authored and
pnowojski
committedMay 13, 2020

Commits on May 12, 2020

[FLINK-17315][tests] Fix and reenable UnalignedCheckpointITCase.

Arvid Heise
authored and
pnowojski
committedMay 12, 2020
[FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint
zhijiangW
committedMay 12, 2020

Commits on May 1, 2020

[FLINK-17315][tests] Temporary disable UnalignedCheckpointITCase.

Arvid Heise
authored and
rmetzger
committedMay 1, 2020

Commits on Apr 27, 2020

[FLINK-17315][tests] Increased timeouts of UnalignedCheckpointITCase.

Arvid Heise
authored and
pnowojski
committedApr 27, 2020
[hotfix][runtime] Code deduplication in ResourceManagerFactory and its implementations.

xintongsong
authored and
tillrohrmann
committedApr 27, 2020
[FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

wsry
authored and
zhijiangW
committedApr 27, 2020

Commits on Apr 22, 2020

[hotfix][typo]Fix typo in RelationalQueryCompilerTest and TpcdsTestProgram
leonardBang
committedApr 22, 2020

Commits on Apr 17, 2020

Revert "[hotfix] Harden ResumeCheckpointManuallyITCase"

ifndef-SleePy
authored and
pnowojski
committedApr 17, 2020
[FLINK-16587][checkpointing] Fix abortion of ChannelStateWriter and add test/IT cases for unaligned checkpoint.

Arvid Heise
authored and
pnowojski
committedApr 17, 2020

Commits on Apr 12, 2020

[FLINK-16949][test] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider
Myasuka
committedApr 12, 2020

Commits on Apr 5, 2020

[FLINK-16913] Migrate StateBackends to use ReadableConfig instead of Configuration
dawidwys
committedApr 5, 2020

Commits on Apr 3, 2020

[FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

mxm
authored and
tillrohrmann
committedApr 3, 2020

Commits on Apr 2, 2020

[FLINK-16917][runtime] Revert FLINK-16245

Arvid Heise
authored and
rmetzger
committedApr 2, 2020
[FLINK-16944][tests] Fix compile errors
zentol
committedApr 2, 2020

Commits on Mar 31, 2020

[FLINK-16245][tests] Adjust BatchFineGrainedRecoveryITCase

Arvid Heise
authored and
zentol
committedMar 31, 2020

Commits on Mar 27, 2020

[FLINK-16222][runtime] Introduce PluginManager to ReporterSetup

afedulov
authored and
zentol
committedMar 27, 2020

Commits on Mar 26, 2020

Commits on Mar 25, 2020

Commits on Mar 24, 2020

[FLINK-15911][runtime] Refactor to create AkkaRpsService with builder class, in order to reduce the number of nested creating methods.

xintongsong
authored and
tillrohrmann
committedMar 24, 2020
[FLINK-15989] Add JVM Direct Error assumption test
azagrebin
committedMar 24, 2020
[FLINK-16225] Add JVM Metaspace Error assumption test
azagrebin
committedMar 24, 2020

Commits on Mar 23, 2020

[hotfix] Harden ResumeCheckpointManuallyITCase

ifndef-SleePy
authored and
pnowojski
committedMar 23, 2020

Commits on Mar 12, 2020

[FLINK-15090][tests] Move streaming env tests to flink-tests

tisonkun
authored and
aljoscha
committedMar 12, 2020

Commits on Mar 11, 2020

[FLINK-16545][build] Remove Eclipse-specific plugins
zentol
committedMar 11, 2020