Commits

Branch selector

 1389856

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 15, 2024

• [FLINK-30613][serializer] Migrate KryoSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  1389856

• [FLINK-30613][serializer] Migrate SimpleTypeSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  32372e7

• [FLINK-30613][serializer] Migrate EnumSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  2a7b904

• [FLINK-30613][serializer] Migrate NFAStateSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  f522e65

• [FLINK-30613][serializer] Migrate AvroSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  85937b8

• [FLINK-30613][serializer] Migrate CompositeTypeSerializerSnapshot to implement new method of resolving schema compatibility

  masteryhx

  committed
  e93b55a

• [FLINK-30613][serializer] Introduce new method to reverse the direction of resolving schema compatibility

  masteryhx

  committed
  13921a0

Commits on Jan 12, 2024

• [FLINK-33705] Upgrade to flink-shaded 18.0

  snuyanzin

  authored
  5d9d874

• [FLINK-33979] Remove TableSink Json Plan & Json IT tests

  Show description for 413aed0
  

  bvarghese1

  authored and

  dawidwys

  committed
  413aed0

• [FLINK-33979] Implement restore tests for TableSink node

  

  bvarghese1

  authored and

  dawidwys

  committed
  9a9b9ce

• Revert "[FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API"

  Show description for f0b28bf
  gyfora

  committed
  f0b28bf

• [FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

  pvary

  authored
  6afe98d

• [FLINK-32256] Remove argument count check

  dawidwys

  committed
  1800b87

• [FLINK-32256] Add ARRAY_MIN function

  Show description for 2c70bd3
  

  hanyuzheng7

  authored and

  dawidwys

  committed
  2c70bd3

• [FLINK-33697][state] Allow incorrect public evolving API violation

  Show description for e6556fa
  pnowojski

  committed
  e6556fa

• [hotfix] Removed incorrect VisibleForTesting

  pnowojski

  committed
  674107b

• [FLINK-33697][state][metrics] Trace RocksDBIncremental remote files download time

  pnowojski

  committed
  7725216

• [FLINK-33697][state] Add custom metrics to the StateBackend interface

  pnowojski

  committed
  40f76e1

• [hotfix][test] Fix some Architecture Violation errors

  pnowojski

  committed
  1d45dd0

• [hotfix][test] Fix propagation of useManagedMemory flag

  pnowojski

  committed
  b660b06

• [FLINK-34047][ci] Make CI scripts agnostic to CI environment (apache#24061)

  Show description for f29ee07
  XComp

  authored
  f29ee07

• [FLINK-33946] [rocksdb] set setAvoidFlushDuringShutdown to true for avoiding Flush when Cancel Task (apache#24069)

  

  mayuehappy

  authored and

  masteryhx

  committed
  aa0c1b5

• [FLINK-34051][checkpoint] Mark SavepointRestoreSettings#restoreMode as @nonnull

  masteryhx

  committed
  ecb6870

• [FLINK-34051][checkpoint] Fix equals/hashCode/toString for SavepointRestoreSettings

  masteryhx

  committed
  7745ef8

• [FLINK-31788][table] TableAggregateFunction supports emitUpdateWithRetract

  Show description for 0156964
  LadyForest

  authored
  0156964

• [FLINK-20281][table] Window aggregation supports changelog stream input

  Show description for df2ecdc
  xuyangzhong

  authored
  df2ecdc

Commits on Jan 11, 2024

• [FLINK-34005] Implement restore tests for MiniBatchAssigner node

  

  bvarghese1

  authored and

  dawidwys

  committed
  881062f

• [FLINK-33518] Remove WatermarkAssigner JSON Plan & IT tests

  Show description for c233ed2
  

  bvarghese1

  authored and

  dawidwys

  committed
  c233ed2

• [FLINK-33518] Implement restore tests for WatermarkAssigner node

  

  bvarghese1

  authored and

  dawidwys

  committed
  23629a8

• [FLINK-33969] Remove TableSource Json Plan & Json IT tests

  

  bvarghese1

  authored and

  dawidwys

  committed
  e98ded8

• [FLINK-33969] Implement restore tests for TableSourceScan node

  

  bvarghese1

  authored and

  dawidwys

  committed
  d6209a1

• [FLINK-33881][state] Avoid copy and update value in TtlListState#getUnexpiredOrNull

  

  ljz2051

  authored and

  masteryhx

  committed
  907d0f3

• [FLINK-33905][core] Unify the provision of metadata in FailureEnricher.Context

  Show description for 06b46a9
  

  WencongLiu

  authored and

  xintongsong

  committed
  06b46a9

• [FLINK-33905][core] Unify the provision of metadata in Sink.InitContext

  

  WencongLiu

  authored and

  xintongsong

  committed
  a6fc334

• [FLINK-33905][core] Unify the provision of metadata in SourceReaderContext

  

  WencongLiu

  authored and

  xintongsong

  committed
  b9e9997

Pagination

PreviousNext