Commits

Branch selector

 fb58380

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 26, 2024

• [FLINK-35162][state] Attach the keyGroup and payload into RecordContext

  

  ljz2051

  authored and

  masteryhx

  committed
  fb58380

  Copy full SHA for fb58380

• [FLINK-35162][state]Support grouping state get and put access

  

  ljz2051

  authored and

  masteryhx

  committed
  1c4eb91

  Copy full SHA for 1c4eb91

• [FLINK-35125][state] Implement ValueState for ForStStateBackend

  

  ljz2051

  authored and

  masteryhx

  committed
  e057010

  Copy full SHA for e057010

• [FLINK-35190][table-api] Support create materialized table syntax

  Show description for 512f3fb
  

  hackergin

  authored and

  lsyldliu

  committed
  512f3fb

  Copy full SHA for 512f3fb

• [FLINK-35047][state] Support FlinkEnv to init ForSt

  masteryhx

  committed
  19577b0

  Copy full SHA for 19577b0

• [FLINK-35047][state] Introduce ForStStateBackend and ForStKeyedStateBackend

  masteryhx

  committed
  417484e

  Copy full SHA for 417484e

• [FLINK-35047][state] Support restoring and building ForSt

  masteryhx

  committed
  625d8a5

  Copy full SHA for 625d8a5

• [FLINK-35047][state] Introduce ResourceContainer for ForStStateBackend

  masteryhx

  committed
  5f5d502

  Copy full SHA for 5f5d502

• [FLINK-35047][state] Introduce Metrics for ForStStateBackend

  masteryhx

  committed
  8411367

  Copy full SHA for 8411367

• [FLINK-35047][state] Introduce ForSt related options

  masteryhx

  committed
  92d7f65

  Copy full SHA for 92d7f65

• [FLINK-35047][state] Introduce forstjni dependency

  masteryhx

  committed
  629c357

  Copy full SHA for 629c357

Commits on Apr 25, 2024

• [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.

  reswqa

  committed
  259aef0

  Copy full SHA for 259aef0

• [FLINK-31223][test] Abstract SqlClientTestBase.

  reswqa

  committed
  6392f81

  Copy full SHA for 6392f81

• [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

  reswqa

  committed
  63f02a0

  Copy full SHA for 63f02a0

• [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (apache#24705)

  zoltar9264

  authored
  797cb9c

  Copy full SHA for 797cb9c

• [hotfix][docs] Fix the invalid link in 1.18 release note

  

  yebukong

  authored and

  reswqa

  committed
  df4685a

  Copy full SHA for df4685a

• [FLINK-35156][Runtime] Make operators of DataStream V2 integrate with async state processing

  

  Zakelly

  authored and

  fredia

  committed
  a87db93

  Copy full SHA for a87db93

• [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility

  

  RocMarshal

  authored and

  1996fanrui

  committed
  92eef24

  Copy full SHA for 92eef24

• [FLINK-29050][test-utils] Use JUnit5 to re-write AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase and tag the corresponding old implementation classes as deprecated

  

  RocMarshal

  authored and

  1996fanrui

  committed
  29a0455

  Copy full SHA for 29a0455

• [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix.

  

  RocMarshal

  authored and

  1996fanrui

  committed
  ffa639a

  Copy full SHA for ffa639a

• [FLINK-35088][core] Watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

  

  elon-X

  authored and

  1996fanrui

  committed
  0953199

  Copy full SHA for 0953199

Commits on Apr 24, 2024

• [FLINK-35188][table-api] Introduce RefreshHandler interface to support materialized table

  lsyldliu

  committed
  8576178

  Copy full SHA for 8576178

• [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table

  lsyldliu

  committed
  2a9876d

  Copy full SHA for 2a9876d

• [FLINK-35148][core] Improve InstantiationUtil for checking nullary public constructor

  

  liuml07

  authored and

  xintongsong

  committed
  9cc6498

  Copy full SHA for 9cc6498

• [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small

  

  jiangxin369

  authored and

  reswqa

  committed
  712d980

  Copy full SHA for 712d980

Commits on Apr 23, 2024

• [FLINK-34444] Initial implementation of JM operator metric rest api (apache#24564)

  Show description for d453baf
  mas-chen

  authored
  d453baf

  Copy full SHA for d453baf

• [FLINK-35158][Core/API] Move functional interfaces about consumers from core module to core-api

  

  Zakelly

  authored and

  fredia

  committed
  8475d28

  Copy full SHA for 8475d28

• [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  ea2eabe

  Copy full SHA for ea2eabe

Commits on Apr 22, 2024

• [FLINK-35028][runtime] Timer firing under async execution model

  fredia

  committed
  0b2e988

  Copy full SHA for 0b2e988

• [FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest

  

  kumar-mallikarjuna

  authored and

  twalthr

  committed
  51d015b

  Copy full SHA for 51d015b

• [FLINK-35097][table] Update RawFormatSerDeSchemaTest to validate multiple serializations/deserializations

  

  kumar-mallikarjuna

  authored and

  twalthr

  committed
  8ffe6d6

  Copy full SHA for 8ffe6d6

• [FLINK-35097][table] Fix 'raw' format deserialization

  

  kumar-mallikarjuna

  authored and

  twalthr

  committed
  3a56c2f

  Copy full SHA for 3a56c2f

• [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  68a84fd

  Copy full SHA for 68a84fd

• [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController

  fredia

  committed
  9336760

  Copy full SHA for 9336760

• [FLINK-35175][filesystem] Avoid reading with ByteBuffer on hadoop version below 3.3.0 (apache#24691)

  masteryhx

  committed
  a4c71c8

  Copy full SHA for a4c71c8

Pagination

Previous

Next