Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on May 22, 2024

• chore: Update pekko version

  He-Pin

  authored
  d16a76f

  Copy full SHA for d16a76f

• [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context

  reswqa

  committed
  e502d23

  Copy full SHA for e502d23

• [FLINK-34549][API] Expose MetricGroup via RuntimeContext

  reswqa

  committed
  ff93e2a

  Copy full SHA for ff93e2a

• [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext

  reswqa

  committed
  545a005

  Copy full SHA for 545a005

• [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext

  reswqa

  committed
  c431efe

  Copy full SHA for c431efe

• [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext

  reswqa

  committed
  0bc2041

  Copy full SHA for 0bc2041

• [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext

  reswqa

  committed
  ef7f1d0

  Copy full SHA for ef7f1d0

• [FLINK-34549][API] Split partition-wise context from RuntimeContext

  reswqa

  committed
  2b0e303

  Copy full SHA for 2b0e303

• [FLINK-34549][API] Introduce related components for runtime context

  reswqa

  committed
  c17440c

  Copy full SHA for c17440c

• [FLINK-34549][API] Introduces and implements ProcessConfigurable

  reswqa

  committed
  6691dc6

  Copy full SHA for 6691dc6

• [FLINK-34549][API] Introduce SlotSharingGroup for v2 and move MemorySize to flink-core-api

  reswqa

  committed
  1d73510

  Copy full SHA for 1d73510

• [hotfix] Temporarily revert the change that makes the v2 operator inherit from the async operator

  Show description for 4d7aeba
  reswqa

  committed
  4d7aeba

  Copy full SHA for 4d7aeba

• [FLINK-35215][core] Fix the bug when Kryo serialize length is 0

  Show description for c1baf07
  1996fanrui

  committed
  c1baf07

  Copy full SHA for c1baf07

• Revert "[FLINK-34954][core] Kryo Input bug fix"

  Show description for 46db926
  1996fanrui

  committed
  46db926

  Copy full SHA for 46db926

Commits on May 21, 2024

• [FLINK-35383][docs] Update compatibility matrix for 1.19 release

  

  z3d1k

  authored and

  hlteoh37

  committed
  8b73ca9

  Copy full SHA for 8b73ca9

• [hotfix][state] Create new copy for each SerializedCompositeKeyBuilder in ForStStateBackend (#24816)

  zoltar9264

  authored
  5a2c1e0

  Copy full SHA for 5a2c1e0

• [hotfix] [streaming] Correct copying StreamPartitioner in rescale case

  

  ldadima

  authored and

  pnowojski

  committed
  11bd030

  Copy full SHA for 11bd030

• [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  46aaea8

  Copy full SHA for 46aaea8

• [FLINK-35395][core] Fix the example code of KeyedStateStore#getState

  

  usberkeley

  authored and

  reswqa

  committed
  5f5722f

  Copy full SHA for 5f5722f

• [FLINK-35382][test] Disable snapshot-file-merging in ChangelogCompatibilityITCase (#24813)

  ljz2051

  authored
  26b149a

  Copy full SHA for 26b149a

• [FLINK-35379][Checkpoint] Fix incorrect checkpoint notification handling in file merging (#24806)

  Zakelly

  authored
  2bcc308

  Copy full SHA for 2bcc308

• [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: types (#24613)

  GOODBOY008

  authored
  e5398e1

  Copy full SHA for e5398e1

Commits on May 19, 2024

• [FLINK-33983][runtime] Introduce JobEvent and JobEventStore

  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  c7c1d78

  Copy full SHA for c7c1d78

Commits on May 17, 2024

• [FLINK-34615]Create a new class `ExternalizedCheckpointRetention` in python and replace the original class `ExternalizedCheckpointCleanup`.

  Show description for f5a8edb
  

  spoon-lz

  authored and

  Zakelly

  committed
  f5a8edb

  Copy full SHA for f5a8edb

• [FLINK-34615]Renamed class "ExternalizedCheckpointCleanup" to "ExternalizedCheckpointRetention" in Java section.

  

  spoon-lz

  authored and

  Zakelly

  committed
  a438f93

  Copy full SHA for a438f93

• [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `CheckpointConfig` and move it to flink-core.

  

  spoon-lz

  authored and

  Zakelly

  committed
  0b94192

  Copy full SHA for 0b94192

• [FLINK-35030][runtime] Introduce Epoch Manager for under async execution (#24748)

  fredia

  authored
  f1ecb9e

  Copy full SHA for f1ecb9e

• [FLINK-35356][State] State descriptor and implementation for async reducing state (#24798)

  Zakelly

  authored
  cc21eec

  Copy full SHA for cc21eec

Commits on May 16, 2024

• [hotfix] Mention mTLS in SSL documentation page (#24755)

  rmetzger

  authored
  48e5a39

  Copy full SHA for 48e5a39

• [FLINK-32828] Properly initialize initial splits in WatermarkOutputMultiplexer

  Show description for 7fd6c6d
  pnowojski

  committed
  7fd6c6d

  Copy full SHA for 7fd6c6d

• [hotfix] Allow to use per split output via SourceOperatorTestContext

  pnowojski

  committed
  4139106

  Copy full SHA for 4139106

• [hotfix] Allow configuring initial splits in SourceOperatorTestContext

  pnowojski

  committed
  f5ceb78

  Copy full SHA for f5ceb78

• [hotfix] Make MockSourceSplit#addRecord calls chainable

  pnowojski

  committed
  8df0466

  Copy full SHA for 8df0466

• [FLINK-35346][table-common] Introduce workflow scheduler interface for materialized table

  Show description for 1378979
  lsyldliu

  authored
  1378979

  Copy full SHA for 1378979

• [FLINK-35225][Web] Remove Execution mode in Flink WebUI

  1996fanrui

  committed
  48c14fe

  Copy full SHA for 48c14fe

Pagination

Previous

Next