Commits

History for

Commits on Jul 22, 2020

Commits on Jul 16, 2020

[FLINK-18163][task] Add RecordWriter.volatileFlusherException

rkhachatryan
authored and
pnowojski
committedJul 16, 2020

Commits on Jul 15, 2020

[FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcurrentReadStateAndProcessAndClose

wsry
authored and
zhijiangW
committedJul 15, 2020

Commits on Jul 9, 2020

[FLINK-18533][coordination] Disable cancellation of unknown deployments
zentol
committedJul 9, 2020

Commits on Jul 8, 2020

[FLINK-17075][coordination] Reconcile deployed Executions
zentol
committedJul 8, 2020

Commits on Jul 3, 2020

[FLINK-18471] Remove references to org.uncommons.maths:uncommons-maths:1.2.2a in flink-runtime
rmetzger
committedJul 3, 2020
[FLINK-15416][network] Remove ignored PartitionRequestClientFactoryTest.testResourceReleaseAfterInterruptedConnect

rkhachatryan
authored and
zhijiangW
committedJul 3, 2020
[FLINK-15416][network] Retry connection to the upstream task

HuangZhenQiu
authored and
zhijiangW
committedJul 3, 2020

Commits on Jul 2, 2020

[FLINK-18336][checkpointing] Ignore failures of past checkpoints in CheckpointFailureManager

rkhachatryan
authored and
zhijiangW
committedJul 2, 2020
[hotfix][checkpointing] Extract CheckpointFailureManager.handleCheckpointException method

rkhachatryan
authored and
zhijiangW
committedJul 2, 2020

Commits on Jun 29, 2020

[FLINK-18435][metrics] Add support for intercepting reflection-based instantiations
zentol
committedJun 29, 2020

Commits on Jun 25, 2020

[FLINK-17300] Log the lineage information between ExecutionAttemptID and AllocationID

KarmaGYZ
authored and
tillrohrmann
committedJun 25, 2020

Commits on Jun 24, 2020

[FLINK-18430][DataStream API] Classify CheckpointedFunction and CheckpointListener as @public
StephanEwen
committedJun 24, 2020
[hotfix][DataStream API] Fix checkstyle issues and JavaDocs in CheckpointListener.
StephanEwen
committedJun 24, 2020
[FLINK-18429][DataStream API] Make CheckpointListener.notifyCheckpointAborted(checkpointId) a default method.
StephanEwen
committedJun 24, 2020
[FLINK-18426] Remove incompatible deprecated keys from ClusterOptions
tillrohrmann
committedJun 24, 2020
[FLINK-17579] Allow user to set the TaskManager ResourceID in standalone mode

KarmaGYZ
authored and
tillrohrmann
committedJun 24, 2020
[hotfix] Simplify the lambda expression in TaskManagerRunner

KarmaGYZ
authored and
tillrohrmann
committedJun 24, 2020
[hotfix] Fix the access modifiers in TaskManagerRunner

KarmaGYZ
authored and
tillrohrmann
committedJun 24, 2020

Commits on Jun 23, 2020

[FLINK-18348] RemoteInputChannel should checkError before checking partitionRequestClient

Jiayi-Liao
authored and
pnowojski
committedJun 23, 2020
[FLINK-17298] Log the lineage information between SlotRequestID and AllocationID

KarmaGYZ
authored and
tillrohrmann
committedJun 23, 2020
[FLINK-18407][runtime] Harden SlotPoolImpl#maybeRemapOrphanedAllocation
zhuzhurk
committedJun 23, 2020
[hotfix][runtime] Simplify SlotPoolImpl#maybeRemapOrphanedAllocation
zhuzhurk
committedJun 23, 2020
[FLINK-17297] Log the lineage information between ExecutionAttemptID and SlotRequestID

KarmaGYZ
authored and
tillrohrmann
committedJun 23, 2020
[hotfix][runtime] Fix code-style in ZooKeeperJobGraphStore

zhengcanbin
authored and
tillrohrmann
committedJun 23, 2020
[hotfix][runtime] Fix code style in RunningJobsRegistry

zhengcanbin
authored and
tillrohrmann
committedJun 23, 2020
[hotfix] Fix checkstyile violations in BashJavaUtilsTest
tillrohrmann
committedJun 23, 2020
[hotfix] Fix checkstyle violations in JobManagerProcessUtilsTest
tillrohrmann
committedJun 23, 2020
[FLINK-18353] Make enabling of the JVM Direct Memory limit configurable for JM

azagrebin
authored and
tillrohrmann
committedJun 23, 2020

Commits on Jun 22, 2020

[hotfix] Remove unused SlotPoolImpl.get(SlotRequestId)
tillrohrmann
committedJun 22, 2020
[FLINK-18406] Add Nullable annotation to DualKeyLinkedMap.getValueByKeyA
tillrohrmann
committedJun 22, 2020
[FLINK-18372][runtime] Fix NPE problem when a slot is offered before JM is connected to a RM
zhuzhurk
committedJun 22, 2020

Commits on Jun 20, 2020

[FLINK-10213] Task managers cache a negative DNS lookup of the blob server indefinitely

joey
authored and
tillrohrmann
committedJun 20, 2020

Commits on Jun 19, 2020

[FLINK-18205][security] Mitigate the use of reflection in HadoopModule

KarmaGYZ
authored and
zentol
committedJun 19, 2020