Commits

Breadcrumbs

History for

ond7c0753

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 29, 2022

• [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

  Show description for f42a92c
  

  wanglijie95

  authored and

  zhuzhurk

  committed
  f42a92c

  Copy full SHA for f42a92c

Commits on Jan 28, 2022

• [FLINK-25479][rpc] Serialize TaskStateSnapshot when sending to JM from TM

  Show description for 53c3525
  rkhachatryan

  committed
  53c3525

  Copy full SHA for 53c3525

Commits on Jan 26, 2022

• [FLINK-25673][tests] Wait until all slots are freed

  dmvk

  authored
  d7bc8e2

  Copy full SHA for d7bc8e2

Commits on Jan 24, 2022

• [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has completed writing

  Show description for 4050cf3
  

  zuston

  authored and

  gaoyunhaii

  committed
  4050cf3

  Copy full SHA for 4050cf3

Commits on Jan 21, 2022

• [FLINK-25277][flink-runtime] add shutdown hook to stop TaskExecutor on SIGTERM

  

  niklassemmler

  authored and

  tillrohrmann

  committed
  b67865b

  Copy full SHA for b67865b

• [FLINK-25199][network] Make sure StreamEdges are unique

  Show description for 5192fd7
  pnowojski

  committed
  5192fd7

  Copy full SHA for 5192fd7

Commits on Jan 20, 2022

• [FLINK-25709] Always delete non-deterministic working directories

  Show description for 035b055
  tillrohrmann

  committed
  035b055

  Copy full SHA for 035b055

• [FLINK-24163][tests] Reduce key space in PartiallyFinishedSourcesITCase

  Show description for d33c39d
  

  rkhachatryan

  authored and

  gaoyunhaii

  committed
  d33c39d

  Copy full SHA for d33c39d

Commits on Jan 19, 2022

• [FLINK-25402] Introduce ClusterOptions.PROCESS_WORKING_DIR_BASE for configuring a process directory

  Show description for 09deea1
  tillrohrmann

  committed
  09deea1

  Copy full SHA for 09deea1

• [FLINK-25402] Make JobManager process resource id configurable via jobmanager.resource-id

  tillrohrmann

  committed
  f107710

  Copy full SHA for f107710

• [FLINK-25399][tests] Use FS-based changelog in PartiallyFinishedSourcesITCase

  rkhachatryan

  committed
  5e680fa

  Copy full SHA for 5e680fa

• [FLINK-25194] Implement an API for duplicating artefacts

  dawidwys

  committed
  fc1d635

  Copy full SHA for fc1d635

• [refactor] Make CheckpointStateOutputStream a top level class

  dawidwys

  committed
  72b0e9f

  Copy full SHA for 72b0e9f

Commits on Jan 18, 2022

• [FLINK-25637][network] Make sort-shuffle the default shuffle implementation for batch jobs

  Show description for ed699b6
  

  kevin.cyj

  committed
  ed699b6

  Copy full SHA for ed699b6

• [FLINK-25638][network] Increase the default write buffer size of sort-shuffle to 16M

  Show description for 4275525
  

  kevin.cyj

  committed
  4275525

  Copy full SHA for 4275525

• [FLINK-24899][network] Enable data compression for blocking shuffle by default

  Show description for a14c554
  

  SteNicholas

  authored and

  kevin.cyj

  committed
  a14c554

  Copy full SHA for a14c554

Commits on Jan 17, 2022

• [FLINK-25395][state] Don't discard changelog shared state on TM

  Show description for e28f4e2
  rkhachatryan

  committed
  e28f4e2

  Copy full SHA for e28f4e2

Commits on Jan 14, 2022

• [FLINK-25570][tests] Ignore TypeSerializer tests for nested serializers based on SimpleVersionedSerializerTypeSerializerProxy

  Show description for 10f884c
  fapaul

  committed
  10f884c

  Copy full SHA for 10f884c

Commits on Jan 13, 2022

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

  Show description for 4518a45
  

  matriv

  authored and

  twalthr

  committed
  4518a45

  Copy full SHA for 4518a45

• [FLINK-25569][core] Extract public facing ProcessingTimeService to flink-core

  

  Arvid Heise

  authored and

  fapaul

  committed
  be1e804

  Copy full SHA for be1e804

Commits on Jan 5, 2022

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

  

  paul8263

  authored and

  fapaul

  committed
  dd1fddb

  Copy full SHA for dd1fddb

Commits on Jan 4, 2022

• [FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable

  Show description for 7b43fd7
  

  akalash

  authored and

  tillrohrmann

  committed
  7b43fd7

  Copy full SHA for 7b43fd7

• [FLINK-25105][checkpoint] Enables final checkpoint by default

  Show description for 4d9ea35
  gaoyunhaii

  committed
  4d9ea35

  Copy full SHA for 4d9ea35

Commits on Jan 3, 2022

• [FLINK-23946][clients] Dispatcher in application mode should be able to recover after losing and regaining leadership.

  Show description for 9247bf2
  

  dmvk

  authored and

  tillrohrmann

  committed
  9247bf2

  Copy full SHA for 9247bf2

• Revert "[FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly"

  Show description for 612fa11
  twalthr

  committed
  612fa11

  Copy full SHA for 612fa11

• Revert "[FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable"

  Show description for d6f1298
  twalthr

  committed
  d6f1298

  Copy full SHA for d6f1298

Commits on Dec 30, 2021

• [FLINK-18295][runtime] Change IntermediateDataSet to explicitly have exactly one consumer vertex

  Show description for 35d3d31
  zhuzhurk

  committed
  35d3d31

  Copy full SHA for 35d3d31

Commits on Dec 28, 2021

• [FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable

  tillrohrmann

  committed
  fe3dfbc

  Copy full SHA for fe3dfbc

• [FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly

  tillrohrmann

  committed
  276570e

  Copy full SHA for 276570e

Commits on Dec 17, 2021

• [FLINK-25192][checkpointing] Implement no-claim mode support

  Show description for 08794a6
  dawidwys

  committed
  08794a6

  Copy full SHA for 08794a6

Commits on Dec 16, 2021

• [FLINK-25191] Skip savepoints for recovery

  Show description for b19cc31
  dawidwys

  committed
  b19cc31

  Copy full SHA for b19cc31

Commits on Dec 10, 2021

• [FLINK-24987][streaming-java] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for externalized-checkpoint-retention

  

  Nicolaus Weidner

  authored and

  Airblader

  committed
  f4db43a

  Copy full SHA for f4db43a

• [FLINK-21504][checkpoint] Return the subsumed checkpoint when adding the completed checkpoint

  Myasuka

  committed
  b04646b

  Copy full SHA for b04646b

Commits on Dec 9, 2021

• [FLINK-25155] Implement claim snapshot restore mode

  Show description for 4c4735b
  dawidwys

  committed
  4c4735b

  Copy full SHA for 4c4735b

Commits on Dec 8, 2021

• [FLINK-23532] Remove unnecessary StreamTask#finishTask

  dawidwys

  committed
  2b167ae

  Copy full SHA for 2b167ae

Pagination

Previous

Next