Commits

Commits on Sep 17, 2021

[FLINK-23180] Do not initialize checkpoint base locations when checkpointing is disabled

Jiayi-Liao
and
Jiayi Liao
committedSep 17, 2021

Commits on Sep 3, 2021

[FLINK-24120] Add docs for using environment variable MALLOC_ARENA_MAX to avoid unlimited memory increasing

Jiayi-Liao
authored and
tillrohrmann
committedSep 3, 2021

Commits on Aug 10, 2021

[FLINK-23208] let late processing timers fired immediately

Jiayi-Liao
authored and
pnowojski
committedAug 10, 2021

Commits on Dec 11, 2020

[hotfix][javadocs] Fix typo
Jiayi-Liao
committedDec 11, 2020

Commits on Oct 14, 2020

[FLINK-16620] - Add attempt information in TaskInfo

Jiayi-Liao
authored and
pnowojski
committedOct 14, 2020

Commits on Oct 13, 2020

[FLINK-16753][checkpointing] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable
Jiayi-Liao
committedOct 13, 2020

Commits on Oct 12, 2020

[FLINK-18068] Use FatalErrorHandler to handle the error thrown from executing on main thread in YarnResourceManagerDriver

Jiayi-Liao
authored and
tillrohrmann
committedOct 12, 2020

Commits on Jun 23, 2020

[FLINK-18348] RemoteInputChannel should checkError before checking partitionRequestClient

Jiayi-Liao
authored and
pnowojski
committedJun 23, 2020

Commits on Jun 7, 2020

[FLINK-18067][yarn] Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_SCHEDULER_MINIMUM_ALLOCATION_MB

Jiayi-Liao
authored and
xintongsong
committedJun 7, 2020

Commits on Jun 5, 2020

[FLINK-17816][metrics] Schedule latency markers with fixed delay
Jiayi-Liao
committedJun 5, 2020