Commits

Branch selector

 b1025e6

User selector

All users

Datepicker

All time

Commit History

Commits on May 28, 2024

• [FLINK-35454] Allow connector classes to depend on internal Flink util classes

  

  vahmed-hamdy

  authored and

  JingGe

  committed
  b1025e6

  Copy full SHA for b1025e6

• [review] Fix missing licenses

  uce

  committed
  26e8031

  Copy full SHA for 26e8031

• [FLINK-26808][rest] Only accept file upload at mutlipart routes

  uce

  committed
  440076a

  Copy full SHA for 440076a

• [FLINK-26808][rest] Factor out getHandlerRoutes(RestHandlerSpecification)

  uce

  committed
  77231de

  Copy full SHA for 77231de

• [FLINK-26808][rest] Add MultipartRoutes utility

  uce

  committed
  3713793

  Copy full SHA for 3713793

• [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode

  lsyldliu

  committed
  49f2225

  Copy full SHA for 49f2225

• [FLINK-35425][table-common] Introduce IntervalFreshness to support materialized table full refresh mode

  lsyldliu

  committed
  61a68bc

  Copy full SHA for 61a68bc

• [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359

  

  zoltar9264

  authored and

  zhuzhurk

  committed
  6c41771

  Copy full SHA for 6c41771

• [FLINK-35457][checkpoint] Hotfix! close physical file under the protection of lock (apache#24846)

  fredia

  authored
  1e996b8

  Copy full SHA for 1e996b8

• [FLINK-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt (apache#24847)

  masteryhx

  committed
  9fbe9f3

  Copy full SHA for 9fbe9f3

• [FLINK-35465][runtime] Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  e964af3

  Copy full SHA for e964af3

• [FLINK-33892][runtime] Support JobMaster fetch and retain partition metrics on TaskManagers during job recovery.

  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  3206659

  Copy full SHA for 3206659

• [FLINK-33892][runtime] Reset dynamic decided parallelism before compute parallelism store.

  Show description for b8173eb
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  b8173eb

  Copy full SHA for b8173eb

Commits on May 27, 2024

• FLINK-33759: add support for nested array with row/map type

  

  ukby1234

  authored and

  JingGe

  committed
  57b2005

  Copy full SHA for 57b2005

• [FLINK-34379][table] Fix adding catalogtable logic

  

  jeyhunkarimov

  authored and

  JingGe

  committed
  87b7193

  Copy full SHA for 87b7193

• [FLINK-35434][statebackend] ForSt supports to pass db exception to runtime

  

  zoltar9264

  authored and

  masteryhx

  committed
  2f7099e

  Copy full SHA for 2f7099e

• [FLINK-35434][state] Allow StateExecutor pass exception to runtime

  

  zoltar9264

  authored and

  masteryhx

  committed
  f926d2a

  Copy full SHA for f926d2a

• [FLINK-35403][table] Allow skipping invocation of function calls while constant-folding

  AlanConfluent

  authored
  efcd146

  Copy full SHA for efcd146

• [FLINK-34993][flink-sql-parser] Support MODEL syntax in parser

  

  lihaosky

  authored and

  twalthr

  committed
  4d39738

  Copy full SHA for 4d39738

• [FLINK-35342][table] Fix the unstable MaterializedTableStatementITCase test due to wrong job status check logic

  Show description for 90e2d6c
  hackergin

  authored
  90e2d6c

  Copy full SHA for 90e2d6c

• [FLINK-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast

  

  SinBex

  authored and

  zhuzhurk

  committed
  4b342da

  Copy full SHA for 4b342da

• [FLINK-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection

  

  X-czh

  authored and

  reswqa

  committed
  f860631

  Copy full SHA for f860631

• [FLINK-34123][core][type] Introduce built-in serialization support for Map, List, and Collection

  

  X-czh

  authored and

  reswqa

  committed
  73676da

  Copy full SHA for 73676da

• [hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context

  reswqa

  committed
  c3221a6

  Copy full SHA for c3221a6

Commits on May 26, 2024

• [FLINK-35446][checkpoint] Fix NPE when disabling file merging but restoring from merged files

  Show description for 096b4a6
  Zakelly

  committed
  096b4a6

  Copy full SHA for 096b4a6

Commits on May 25, 2024

• [FLINK-35215][core] Add a test for deserializing an object whose serialization result is an empty byte array

  1996fanrui

  committed
  5b535e1

  Copy full SHA for 5b535e1

Commits on May 24, 2024

• [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor

  Show description for 467f94f
  

  jectpro7

  authored and

  Zakelly

  committed
  467f94f

  Copy full SHA for 467f94f

• [FLINK-35437] Rewrite BlockStatementGrouper so that it uses less memory (apache#24834)

  dawidwys

  authored
  3d40bd7

  Copy full SHA for 3d40bd7

• [FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all task attempts finished

  Show description for 54f037f
  Zakelly

  committed
  54f037f

  Copy full SHA for 54f037f

• [FLINK-35347][table] Introduce EmbeddedWorkflowScheduler plugin based on embedded scheduler

  lsyldliu

  committed
  71e6746

  Copy full SHA for 71e6746

• [FLINK-35347][table] Introduce embedded scheduler to support full refresh mode for materialized table

  lsyldliu

  committed
  62b8fee

  Copy full SHA for 62b8fee

• [FLINK-35347][table-common] Introduce RefreshWorkflow related implementation to support full refresh mode for materialized table

  lsyldliu

  committed
  0ec6302

  Copy full SHA for 0ec6302

Commits on May 23, 2024

• [FLINK-35216] Support for RETURNING clause of JSON_QUERY

  dawidwys

  authored
  0737220

  Copy full SHA for 0737220

• [FLINK-35359][config] Make yarn.application-attempts Int type

  Show description for 4f1427c
  

  Sxnan

  authored and

  xintongsong

  committed
  4f1427c

  Copy full SHA for 4f1427c

• [FLINK-35359][config] Make enum options Enum type

  

  Sxnan

  authored and

  xintongsong

  committed
  fa8590d

  Copy full SHA for fa8590d

Pagination

Previous

Next