Commits

Breadcrumbs

History for

ondfb4394

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 6, 2021

• [FLINK-22700] [api] Propagate watermarks to sink API (FLIP-167)

  

  EronWright

  authored and

  tzulitai

  committedJul 6, 2021
  c0244d3

Commits on Jul 5, 2021

• [FLINK-21925][core] Introduce fine-grained.shuffle-mode.all-blocking to avoid resource deadlock in batch jobs that apply fine-grained resource management

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  25fdf54

• [FLINK-21925][core] Introduce #slotSharingGroup(SlotSharingGroup) for configuring slot sharing group with its resource

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  2e86133

• [FLINK-21925][core] Introduce SlotSharingGroupUtils which contains utility for SlotSharingGroup

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  7871a58

• [FLINK-21925][core] Introduce public SlotSharingGroup

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  0544ddd

• [hotfix][core] Check the cpu and heap memory to be positive when building ResourceSpec

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  bc5f36d

• [hotfix][core] Fix typo in the Builder of ResourceSpec

  

  KarmaGYZ

  authored and

  xintongsong

  committedJul 5, 2021
  d0846bb

Commits on Jun 25, 2021

• [hotfix] Fix some typos in comments

  rmetzger

  committedJun 25, 2021
  7475027

• [hotfix][docs] Merge the two Flink POJO definitions to make the definition uniform.

  

  echauchot

  authored and

  pnowojski

  committedJun 25, 2021
  88152c0

• [FLINK-23118] Drop Mesos support

  zentol

  committedJun 25, 2021
  e8b7f3d

• [hotfix][connector/test] Make MockSplitEnumeratorContext implement AutoClosable and shutdown executors at closing

  

  PatrickRen

  authored and

  becketqin

  committedJun 25, 2021
  1418a1d

Commits on Jun 24, 2021

• [FLINK-23085] Move FutureUtils to flink-core

  zentol

  committedJun 24, 2021
  ad47fe2

• [FLINK-23131][conf] Remove scala from PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS

  zentol

  committedJun 24, 2021
  81df551

• [hotfix][table-common] Support prefix map syntax in FactoryUtil

  twalthr

  committedJun 24, 2021
  58e0948

Commits on Jun 23, 2021

• [FLINK-22997] Replace AkkaUtils#get*Timeout*

  zentol

  committedJun 23, 2021
  fecdc59

• [FLINK-23084] Move Executors/-ThreadFactory to flink-core

  zentol

  committedJun 23, 2021
  52609d3

• [FLINK-23084] Move SecurityManager to flink-core

  zentol

  committedJun 23, 2021
  c08bef1

• [hotfix][tests] Use correct variable

  zentol

  committedJun 23, 2021
  4fbf953

• [FLINK-22992][security] Move SSLUtils#is*Enabled to SecurityOptions

  zentol

  committedJun 23, 2021
  5d9e63a

Commits on Jun 22, 2021

• [FLINK-23011] Revert to not emitting IDLE when there are no PartialWatermarks

  dawidwys

  committedJun 22, 2021
  e0614e7

• [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

  zentol

  committedJun 22, 2021
  6168118

• [FLINK-22678][state][changelog] Configurations and user APIs for ChangelogStateBackend

  Zakelly

  committedJun 22, 2021
  641c31e

Commits on Jun 18, 2021

• [FLINK-22878][core] Allow prefix syntax for ConfigOption.mapType

  twalthr

  committedJun 18, 2021
  2b64bf4

• [hotfix][core] Introduce config options constants in ConfigurationTest

  twalthr

  committedJun 18, 2021
  fc4acf4

Commits on Jun 15, 2021

• [FLINK-22963][doc] correct the description of taskmanager.memory.task.heap.size.

  

  CodeCooker17

  authored and

  xintongsong

  committedJun 15, 2021
  c2df238

Commits on May 25, 2021

• [FLINK-18934][runtime] Idle stream does not advance watermark in connected stream

  dawidwys

  committedMay 25, 2021
  18a2a8a

• [FLINK-18934][core] Extract reusable CombinedWatermark class

  dawidwys

  committedMay 25, 2021
  214ba68

Commits on May 18, 2021

• [FLINK-22636][zk] Group job specific zNodes under /jobs zNode

  tillrohrmann

  committedMay 18, 2021
  79936be

Commits on May 12, 2021

• [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster (apache#15131)

  zuston

  committedMay 12, 2021
  3a1b2e1

Commits on May 10, 2021

• [hotfix][core] Remove unused import

  paul8263

  committedMay 10, 2021
  9e1cc0a

Commits on May 8, 2021

• [FLINK-22505][core] Limit the scale of Resource to 8

  

  KarmaGYZ

  authored and

  xintongsong

  committedMay 8, 2021
  ce9d642

Commits on May 7, 2021

• [FLINK-21095][ci] Remove legacy slot management profile

  zentol

  committedMay 7, 2021
  323c662

Commits on May 3, 2021

• [FLINK-14393][webui] Add an option to enable/disable cancel job in web ui

  

  fangyuefy

  authored and

  tillrohrmann

  committedMay 3, 2021
  a1b3fba

Commits on Apr 30, 2021

• [FLINK-22510][core] Format durations with highest unit

  

  Airblader

  authored and

  twalthr

  committedApr 30, 2021
  89c6c03

Commits on Apr 27, 2021

• [FLINK-22476][docs] Extend the description of the config option execution.target

  

  tony810430

  authored and

  tillrohrmann

  committedApr 27, 2021
  bed991f

Pagination

PreviousNext