Commits

Breadcrumbs

History for

onfa8590d

User selector

All users

Datepicker

All time

Commit History

Commits on May 23, 2024

• [FLINK-35359][config] Make duration Configuration Duration type

  

  Sxnan

  authored and

  xintongsong

  committed
  583aadf

  Copy full SHA for 583aadf

Commits on May 21, 2024

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

  ljz2051

  authored
  26b149a

  Copy full SHA for 26b149a

Commits on May 17, 2024

• [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

Commits on May 16, 2024

• [FLINK-32092][tests] Integrate snapshot file-merging with existing IT cases (apache#24789)

  fredia

  authored
  b87ead7

  Copy full SHA for b87ead7

Commits on Apr 25, 2024

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

  

  RocMarshal

  authored and

  1996fanrui

  committed
  ffa639a

  Copy full SHA for ffa639a

Commits on Apr 19, 2024

• [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (apache#23777)

  afedulov

  authored
  7c4dec6

  Copy full SHA for 7c4dec6

Commits on Apr 17, 2024

• [FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStreamOperator during setup

  Show description for 7a90a05
  

  Sxnan

  authored and

  xintongsong

  committed
  7a90a05

  Copy full SHA for 7a90a05

Commits on Apr 10, 2024

• [FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization

  fredia

  committed
  10522ff

  Copy full SHA for 10522ff

Commits on Apr 9, 2024

• [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond

  pnowojski

  committed
  98bd265

  Copy full SHA for 98bd265

Commits on Apr 7, 2024

• [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0

  Show description for 5bbcf8d
  lincoln-lil

  authored
  5bbcf8d

  Copy full SHA for 5bbcf8d

Commits on Apr 3, 2024

• [FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase

  rkhachatryan

  committed
  8756830

  Copy full SHA for 8756830

Commits on Mar 28, 2024

• [FLINK-34922] Adds ITCase for GlobalFailureOnRestart

  Show description for f4c945c
  

  pgaref

  authored and

  zentol

  committed
  f4c945c

  Copy full SHA for f4c945c

Commits on Mar 27, 2024

• [FLINK-34643] Use AdaptiveScheduler in JobIDLoggingITCase

  rkhachatryan

  committed
  d4c1a0a

  Copy full SHA for d4c1a0a

Commits on Mar 25, 2024

• [FLINK-21535][test] Adds proper comment to test methods that are disabled for the AdaptiveScheduler

  XComp

  committed
  9614240

  Copy full SHA for 9614240

• [FLINK-21450][test] Enables tests that were disabled for the AdaptiveScheduler

  Show description for 8f06fb4
  XComp

  committed
  8f06fb4

  Copy full SHA for 8f06fb4

Commits on Mar 22, 2024

• [FLINK-34643][tests] Ignore 'lost leadership' log messages

  rkhachatryan

  committed
  4edafcc

  Copy full SHA for 4edafcc

• [FLINK-34516][checkpoint] Rename the new introduced API to get/setCheckpointingConsistencyMode

  

  Zakelly

  authored and

  masteryhx

  committed
  7794591

  Copy full SHA for 7794591

• [FLINK-34516][checkpoint] Use new CheckpointingMode in flink-core everywhere

  

  Zakelly

  authored and

  masteryhx

  committed
  54ac32f

  Copy full SHA for 54ac32f

• [FLINK-34731][runtime] Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler.

  Show description for cf0d75c
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  cf0d75c

  Copy full SHA for cf0d75c

Commits on Mar 20, 2024

• [FLINK-34718][tests] Exclude operators not meant for adaptive scheduler

  

  RyanSkraba

  authored and

  XComp

  committed
  9ae0d14

  Copy full SHA for 9ae0d14

• [FLINK-34667][state/changelog] Changelog state backend support local rescaling

  fredia

  committed
  501de48

  Copy full SHA for 501de48

Commits on Mar 18, 2024

• [FLINK-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState

  masteryhx

  committed
  e79df35

  Copy full SHA for e79df35

Commits on Mar 15, 2024

• [FLINK-34643][tests] Fix JobIDLoggingITCase

  rkhachatryan

  committed
  6b5ae44

  Copy full SHA for 6b5ae44

Commits on Mar 14, 2024

• [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs

  

  ljz2051

  authored and

  fredia

  committed
  649e2b4

  Copy full SHA for 649e2b4

• [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery

  

  ljz2051

  authored and

  fredia

  committed
  ed75795

  Copy full SHA for ed75795

• [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption

  

  ljz2051

  authored and

  fredia

  committed
  1d1dca6

  Copy full SHA for 1d1dca6

• [FLINK-34543][datastream] Introduce the SortPartition API on PartitionWindowedStream

  

  WencongLiu

  authored and

  reswqa

  committed
  a021db6

  Copy full SHA for a021db6

• [FLINK-34543][datastream] Introduce the Aggregate API on PartitionWindowedStream

  

  WencongLiu

  authored and

  reswqa

  committed
  46ec4b0

  Copy full SHA for 46ec4b0

• [FLINK-34543][datastream] Introduce the Reduce API on PartitionWindowedStream

  

  WencongLiu

  authored and

  reswqa

  committed
  fe88e16

  Copy full SHA for fe88e16

• [FLINK-34543][datastream] Introduce the MapPartition API on PartitionWindowedStream

  

  WencongLiu

  authored and

  reswqa

  committed
  cfbd41e

  Copy full SHA for cfbd41e

Commits on Mar 12, 2024

• [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase (apache#24470)

  fredia

  authored
  94b55d1

  Copy full SHA for 94b55d1

Commits on Mar 8, 2024

• [FLINK-34417] Log Job ID via MDC

  rkhachatryan

  committed
  d6a4eb9

  Copy full SHA for d6a4eb9

• [FLINK-33668][runtime] Decouple the network memory and job topology on result partition side

  

  jiangxin369

  authored and

  reswqa

  committed
  88138d0

  Copy full SHA for 88138d0

• [FLINK-33668][runtime] Decouple the network memory and job topology on input gate side

  

  jiangxin369

  authored and

  reswqa

  committed
  2e25789

  Copy full SHA for 2e25789

Pagination

Previous

Next