Commits

History for

Commits on Dec 28, 2020

[FLINK-20651] Format code with Spotless/google-java-format

Rufus Refactor
authored and
zentol
committedDec 28, 2020

Commits on Nov 26, 2020

Update version to 1.13-SNAPSHOT
dianfu
committedNov 26, 2020

Commits on Nov 5, 2020

[FLINK-19698] Move the CheckpointListener from flink-runtime to flink-core.
becketqin
committedNov 5, 2020

Commits on Oct 19, 2020

[FLINK-13553] Ignore KvStateServerHandlerTest because it is unstable
tillrohrmann
committedOct 19, 2020

Commits on Sep 7, 2020

[FLINK-19035] Remove fold from DataStream API
dawidwys
committedSep 7, 2020

Commits on Aug 19, 2020

[FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope
tisonkun
committedAug 19, 2020

Commits on Jul 22, 2020

[FLINK-18607][build] Give the maven module a human readable name
nielsbasjes
committedJul 22, 2020

Commits on May 22, 2020

[FLINK-13553][qs] Add logging to AbstractServerHandler
GJL
committedMay 22, 2020
[hotfix][qs] Fix logging of exception in RequestWriteListener
GJL
committedMay 22, 2020
[hotfix][tests] Make ClientTest extend TestLogger
GJL
committedMay 22, 2020

Commits on May 20, 2020

[FLINK-8871][checkpoint] Support to cancel checkpoing via notification on task side

Myasuka
authored and
pnowojski
committedMay 20, 2020

Commits on May 18, 2020

Update version to 1.12-SNAPSHOT
pnowojski
committedMay 18, 2020

Commits on May 6, 2020

[FLINK-17501][qs] Improve logging in AbstractServerHandler#channelRead(ChannelHandlerContext, Object)
GJL
committedMay 6, 2020

Commits on Mar 24, 2020

[FLINK-15911][runtime] Support unresolveable external hostname.

xintongsong
authored and
tillrohrmann
committedMar 24, 2020

Commits on Mar 23, 2020

[FLINK-16718][tests] Fix ByteBuf leak in KvStateServerHandlerTest
GJL
committedMar 23, 2020

Commits on Feb 21, 2020

[FLINK-15672][build][tests] Migrate test log4j configurations to log4j2
zentol
committedFeb 21, 2020

Commits on Jan 3, 2020

[FLINK-15371][core][config] Use the new type definition for config options of memory types in TaskManagerOptions.

xintongsong
authored and
tillrohrmann
committedJan 3, 2020

Commits on Dec 9, 2019

Update version to 1.11-SNAPSHOT
GJL
committedDec 9, 2019

Commits on Dec 6, 2019

[hotfix][tests] Consolidate the instantiation of the RocksDBKEyesStateBackendBuilder for tests in a utility class.
StephanEwen
committedDec 6, 2019

Commits on Dec 3, 2019

[FLINK-13986][core][config] Remove legacy config option TaskManagerOptions#LEGACY_MANAGED_MEMORY_SIZE.

xintongsong
authored and
azagrebin
committedDec 3, 2019

Commits on Nov 29, 2019

[FLINK-14762][api] Move JobStatus to flink-core
tisonkun
committedNov 29, 2019

Commits on Nov 22, 2019

[FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. (apache#10184 )

AT-Fieldless
authored and
pnowojski
committedNov 22, 2019

Commits on Nov 8, 2019

[FLINK-14593][client] Port ClusterClient to asynchronous interface version
tisonkun
committedNov 8, 2019

Commits on Nov 6, 2019

[FLINK-13034][state backends] Add isEmpty method for MapState

Myasuka
authored and
StephanEwen
committedNov 6, 2019

Commits on Nov 1, 2019

[FLINK-14496][client] Exclude detach flag from ClusterClient
tisonkun
committedNov 1, 2019

Commits on Oct 15, 2019

[FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

wsry
authored and
aljoscha
committedOct 15, 2019

Commits on Oct 14, 2019

[hotfix] Rename TaskManagerOptions#MANAGED_MEMORY_SIZE and TaskManagerOptions#MANAGED_MEMORY_FRACTION with prefix LEGACY_.

xintongsong
authored and
tillrohrmann
committedOct 14, 2019

Commits on Aug 15, 2019

[FLINK-13530][qs][tests] Increase port range size
zentol
committedAug 15, 2019

Commits on Jul 12, 2019

Update version to 1.10-SNAPSHOT
KurtYoung
committedJul 12, 2019
[FLINK-12602][travis] Correct the flink pom artifactId config and s… (apache#8563 )
sunjincheng121
committedJul 12, 2019

Commits on Mar 6, 2019

[FLINK-11833] [State Backends] Cleanup unnecessary createKeyedStateBackend methods in StateBackend

carp84
authored and
StefanRRichter
committedMar 6, 2019

Commits on Mar 4, 2019

[FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

carp84
authored and
StefanRRichter
committedMar 4, 2019
[FLINK-11804] [State Backends] Make sure the CloseableRegistry used in backend builder is registered with task

carp84
authored and
StefanRRichter
committedMar 4, 2019

Commits on Feb 25, 2019

Update version to 1.9-SNAPSHOT
aljoscha
committedFeb 25, 2019

Commits on Feb 22, 2019

[FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

carp84
authored and
StefanRRichter
committedFeb 22, 2019