Commits

Breadcrumbs

History for

on9336760

User selector

All users

Datepicker

All time

Commit History

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

• [FLINK-33668][runtime] Redefine the redistribution logic of the NetworkBufferPool

  

  jiangxin369

  authored and

  reswqa

  committed
  012b893

  Copy full SHA for 012b893

Commits on Feb 27, 2024

• [FLINK-34454] Introduce StateRecoveryOptions in flink-core and Rename options

  

  Zakelly

  authored and

  masteryhx

  committed
  63dc559

  Copy full SHA for 63dc559

Commits on Feb 22, 2024

• [FLINK-34455] Move RestoreMode from flink-runtime to flink-core (apache#24320)

  Zakelly

  authored
  80090c7

  Copy full SHA for 80090c7

• [FLINK-29802][state] Add more test cases for changelog native savepoint

  masteryhx

  committed
  9308e10

  Copy full SHA for 9308e10

• Revert "[FLINK-29788][state] Disable changelog temporally when SnapshotMigrationTestBase triggers native savepoint"

  Show description for d03629d
  masteryhx

  committed
  d03629d

  Copy full SHA for d03629d

• Revert "[FLINK-26165][tests] Don't test NATIVE savepoints with Changelog enabled"

  Show description for 49d2daf
  masteryhx

  committed
  49d2daf

  Copy full SHA for 49d2daf

Pagination

Previous

Next