Commits

History for

Commits on Jan 24, 2022

[FLINK-25715][coordination] Allow submission of failed jobs

dmvk
authored and
zentol
committedJan 24, 2022
[FLINK-17808] Rename checkpoint meta file to "_metadata" until it has completed writing

zuston
authored and
gaoyunhaii
committedJan 24, 2022
[hotfix][annotations] Add v1.15 as the next Flink version to master

matriv
authored and
twalthr
committedJan 24, 2022

Commits on Jan 20, 2022

[FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui
authored and
wsry
committedJan 20, 2022
[FLINK-11838][fs][gs] Create Google Storage file system with RecoverableWriter support

galenwarren
authored and
xintongsong
committedJan 20, 2022

Commits on Jan 19, 2022

Commits on Jan 18, 2022

[FLINK-25637][network] Make sort-shuffle the default shuffle implementation for batch jobs
wsry
committedJan 18, 2022
[FLINK-25638][network] Increase the default write buffer size of sort-shuffle to 16M
wsry
committedJan 18, 2022
[FLINK-25639][network] Increase the default read buffer size of sort-shuffle to 64M
wsry
committedJan 18, 2022
[FLINK-24899][network] Enable data compression for blocking shuffle by default

SteNicholas
authored and
wsry
committedJan 18, 2022
[FLINK-25073][streaming] Introduce TreeMode description for vertices

龙三
authored and
gaoyunhaii
committedJan 18, 2022

Commits on Jan 16, 2022

[FLINK-23976][metrics] Add additional job status metrics
zentol
committedJan 16, 2022

Commits on Jan 15, 2022

[FLINK-10804] [core] [runtime] Transfer suppressed exceptions with SerializedThrowable

klistopad
authored and
tillrohrmann
committedJan 15, 2022

Commits on Jan 14, 2022

[FLINK-25570][streaming] Add topology extension points to Sink V2.

Arvid Heise
authored and
fapaul
committedJan 14, 2022
[FLINK-24886][core] Let TimeUtils parse 10 m as 10 minutes

liuyongvs
authored and
tillrohrmann
committedJan 14, 2022

Commits on Jan 13, 2022

[FLINK-25351][annotations] Introduce FlinkVersion as a global enum

matriv
authored and
twalthr
committedJan 13, 2022
[hotfix] Rename some methods of NetworkBufferPool and add more comments for better readability

wsry
authored and
pnowojski
committedJan 13, 2022
[FLINK-25569][core] Add decomposed Sink V2 interface.

Arvid Heise
authored and
fapaul
committedJan 13, 2022
[FLINK-25569][core] Mark SimpleVersionedSerializer as PublicEvolving

Fabian Paul
authored and
fapaul
committedJan 13, 2022
[FLINK-25569][core] Mark UserCodeClassLoader as PublicEvolving

Fabian Paul
authored and
fapaul
committedJan 13, 2022
[FLINK-25569][core] Extract public facing ProcessingTimeService to flink-core

Arvid Heise
authored and
fapaul
committedJan 13, 2022
[hotfix][core] Fix javadoc in (Global)committer for retries.

Arvid Heise
authored and
fapaul
committedJan 13, 2022

Commits on Jan 11, 2022

[FLINK-25553][filesystem] Remove MapR filesystem
MartijnVisser
committedJan 11, 2022

Commits on Jan 10, 2022

[hotfix][doc] fix typo of 'note that' and 'now that'

hackergin
authored and
fapaul
committedJan 10, 2022

Commits on Jan 6, 2022

[FLINK-25487][core][table-planner-loader] Improve verbosity of classloading errors

slinkydeveloper
authored and
twalthr
committedJan 6, 2022

Commits on Jan 5, 2022

[FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

paul8263
authored and
fapaul
committedJan 5, 2022

Commits on Dec 30, 2021

[FLINK-25398] Show complete stacktrace when requesting thread dump

zuston
authored and
tillrohrmann
committedDec 30, 2021

Commits on Dec 14, 2021

[FLINK-25020] Properly forward exception
zentol
committedDec 14, 2021