Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 18, 2024

• [FLINK-32086][checkpointing] Cleanup orphan file-merging managed directory on exit of TM

  Show description for 99d6fd3
  

  zoltar9264

  authored and

  Zakelly

  committed
  99d6fd3

• [FLINK-32086][checkpointing] Fix deletion fail of file-merging managed dir

  

  zoltar9264

  authored and

  Zakelly

  committed
  9f90e58

• [FLINK-32086][checkpointing] Normalize file-merging sub dir

  

  zoltar9264

  authored and

  Zakelly

  committed
  6723ad7

• [hotfix][docs] Fix the Incorrect syntax GROUPING SET in group-agg.md(apache#24947)

  ZmmBigdata

  authored
  fe8ba73

• Fix artifactId of flink-migration-test-utils module

  

  wForget

  authored and

  XComp

  committed
  fdd0f80

• fixup! [FLINK-34252][table] Optimize WatermarkAssignerOperator to avoid calling System.currentTimeMillis per every record

  pnowojski

  committed
  d93e92c

• [FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssignerOperator to prevent erroneous idle WatermarkStatus

  

  dchristle

  authored and

  pnowojski

  committed
  d42a1ed

Commits on Jun 17, 2024

• [FLINK-35601][test] Revert the junit5 migration of InitOutputPathTest

  Show description for 3a15d1c
  

  reswqa

  authored and

  1996fanrui

  committed
  3a15d1c

Commits on Jun 14, 2024

• [FLINK-34918][table] Support ALTER CATALOG COMMENT syntax

  

  liyubin117

  authored and

  reswqa

  committed
  2385cc0

• [hotfix] Fix exception when setting 'state.backend.forst.compression.per.level' in yaml

  Show description for adfbbbd
  Zakelly

  committed
  adfbbbd

• [FLINK-35371][security] Add configuration for SSL keystore and truststore type

  ammar-master

  authored
  0919ff2

• [FLINK-34917][table] Support CREATE CATALOG IF NOT EXISTS with comment

  Show description for 4044b9e
  liyubin117

  authored
  4044b9e

• [FLINK-32091][checkpoint] Add file size metrics for file-merging (apache#24922)

  fredia

  authored
  5497868

• [FLINK-35597][test] Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts

  

  liyubin117

  authored and

  1996fanrui

  committed
  bc5c4b8

• [hotfix] Improve execution.checkpointing.unaligned.interruptible-timers.enabled documentation

  pnowojski

  committed
  6f47913

• [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (apache#24905)

  pan3793

  authored
  6c05981

• [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish (apache#24757)

  elon-X

  authored
  93b9bdf

Commits on Jun 13, 2024

• [FLINK-34172] Add support for altering a distribution via ALTER TABLE

  jnh5y

  authored
  d0f9bb4

• [FLINK-35164][table] Support ALTER CATALOG RESET syntax

  Show description for 9d16903
  liyubin117

  authored
  9d16903

• [FLINK-35378][FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction. This closes apache#24805

  Show description for f0b0127
  MartijnVisser

  authored
  f0b0127

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

  GOODBOY008

  authored
  14fdd13

• [FLINK-34482][checkpoint] Refactor checkpoint section in doc

  masteryhx

  committed
  26e6193

• [FLINK-34482][checkpoint] Rename checkpointing options

  masteryhx

  committed
  38070a1

• [FLINK-34977][test] Introduce DataStream V2 IT Tests

  Show description for 03b3d26
  

  jeyhunkarimov

  authored and

  reswqa

  committed
  03b3d26

• [FLINK-34977][API] Support compile-time checks for invalid states

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  2a6ee64

• [FLINK-34977][API] Introduce State Access on DataStream API V2

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  9a47e37

• [FLINK-34977][API] Move State interfaces to flink-core-api

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  a3ef9b7

• [FLINK-34977][API] Add useStates to the ProcessFunction

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  3c77ccc

• [FLINK-34977][API] Support State Declarations

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  2998ef1

• [FLINK-34977][API] Move Reduce and Aggregate functions to flink-core-api

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  f0c3b98

• [FLINK-34977][API] Introduce Type Descriptors

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  c6c7c99

• [FLINK-34977][API] Introduce TypeDescriptor and TypeUtils

  

  jeyhunkarimov

  authored and

  reswqa

  committed
  f91730d

Commits on Jun 12, 2024

• [FLINK-35570][Checkpoint] Consider PlaceholderStreamStateHandle in file merging

  Show description for fb5fd48
  Zakelly

  committed
  fb5fd48

• [FLINK-35528][task] Skip execution of interruptible mails when yielding

  Show description for 77cd1cd
  pnowojski

  committed
  77cd1cd

• [FLINK-20217][docs] Regenerate docs

  pnowojski

  committed
  986d06d

Pagination

PreviousNext