Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 28, 2021

• [FLINK-24374] Retry querying for checkpoint stats

  Show description for 1261d66
  dawidwys

  committed
  1261d66

  Copy full SHA for 1261d66

Commits on Sep 24, 2021

• [FLINK-24280] Support manual checkpoints triggering from a MiniCluster

  Show description for 7952960
  dawidwys

  committed
  7952960

  Copy full SHA for 7952960

Commits on Sep 22, 2021

• [hotfix][test] Do not hide original exception in the tests

  pnowojski

  committed
  d2200cc

  Copy full SHA for d2200cc

Commits on Sep 17, 2021

• [FLINK-23180] Do not initialize checkpoint base locations when checkpointing is disabled

  Show description for 164a59a
  

  Jiayi-Liao

  and

  Jiayi Liao

  authored
  164a59a

  Copy full SHA for 164a59a

Commits on Sep 14, 2021

• [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency

  Show description for 13ef5ac
  rkhachatryan

  committed
  13ef5ac

  Copy full SHA for 13ef5ac

Commits on Sep 8, 2021

• [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase

  Show description for c740f92
  

  rkhachatryan

  authored and

  gaoyunhaii

  committed
  c740f92

  Copy full SHA for c740f92

• [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase

  Show description for 6eff01b
  gaoyunhaii

  committed
  6eff01b

  Copy full SHA for 6eff01b

Commits on Sep 7, 2021

• [FLINK-24162][tests] Check MAX_WATERMARK per attempt in FLIP-147 tests

  Show description for 10eecac
  rkhachatryan

  committed
  10eecac

  Copy full SHA for 10eecac

• [hotfix][tests] Parameterize PartiallyFinishedSourcesITCase with failover strategy

  rkhachatryan

  committed
  c9282cf

  Copy full SHA for c9282cf

• [FLINK-24069][tests] Added exponentially increasing checkpoint interval for every next attempt of testIgnoreInFlightDataDuringRecovery

  

  akalash

  authored and

  dawidwys

  committed
  311eaaa

  Copy full SHA for 311eaaa

• [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one

  

  akalash

  authored and

  dawidwys

  committed
  2d2b719

  Copy full SHA for 2d2b719

Commits on Sep 3, 2021

• [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

  Show description for 6b4f8a4
  

  Aitozi

  authored and

  tillrohrmann

  committed
  6b4f8a4

  Copy full SHA for 6b4f8a4

• [FLINK-21090] Minor code improvements

  Show description for 36f607c
  dawidwys

  committed
  36f607c

  Copy full SHA for 36f607c

• [FLINK-21090] Add tests for stop-with-savepoint and FLIP-147

  

  rkhachatryan

  authored and

  dawidwys

  committed
  f6e7847

  Copy full SHA for f6e7847

• [FLINK-24091][tests] Harden TaskManagerProcessFailureBatchRecoveryITCase

  Show description for 338ae25
  tillrohrmann

  committed
  338ae25

  Copy full SHA for 338ae25

• [FLINK-20427] Remove configuration option to prefer checkpoints over newer savepoints

  

  Nicolaus Weidner

  authored and

  tillrohrmann

  committed
  eb8c21c

  Copy full SHA for eb8c21c

Commits on Sep 2, 2021

• [FLINK-24047][tests] Retry if leader election is in progress

  zentol

  committed
  9aa70fe

  Copy full SHA for 9aa70fe

Commits on Sep 1, 2021

• [FLINK-23797][tests] Wait for all task running before savepoint for all tests in SavepointITCase

  

  akalash

  authored and

  pnowojski

  committed
  c7bf8b3

  Copy full SHA for c7bf8b3

Commits on Aug 31, 2021

• [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes

  Show description for 0b52bfd
  

  fapaul

  authored and

  AHeise

  committed
  0b52bfd

  Copy full SHA for 0b52bfd

Commits on Aug 30, 2021

• [hotfix] Print the test parameters for UnalignedCheckpointTestBase to help debugging when the case is stuck

  Show description for ee6c887
  

  kevin.cyj

  authored and

  pnowojski

  committed
  ee6c887

  Copy full SHA for ee6c887

Commits on Aug 28, 2021

• Update version to 1.15-SNAPSHOT

  xintongsong

  committed
  fb3849f

  Copy full SHA for fb3849f

Commits on Aug 27, 2021

• [FLINK-23794][tests] Remove InMemoryReporter from MiniClusterResource.

  Show description for 126fafc
  

  Arvid Heise

  authored and

  AHeise

  committed
  126fafc

  Copy full SHA for 126fafc

• [FLINK-23794][tests] Fix InMemoryReporter instantiation by associating each reporter with a unique id that is used to retrieve it.

  

  Arvid Heise

  authored and

  AHeise

  committed
  3dbd9e7

  Copy full SHA for 3dbd9e7

Commits on Aug 26, 2021

• [FLINK-23862][runtime] Replace usages of AbstractInvokable with interface

  Show description for a8ea3c3
  rkhachatryan

  committed
  a8ea3c3

  Copy full SHA for a8ea3c3

• [FLINK-13973][runtime][checkpoint] Fix the state assignments if uidHash is set

  Show description for 8bf1fbd
  gaoyunhaii

  committed
  8bf1fbd

  Copy full SHA for 8bf1fbd

Commits on Aug 23, 2021

• [FLINK-23811][tests] Handle finished subtasks in CommonTestUtils.waitForAllTaskRunning

  Show description for 136bb52
  

  rkhachatryan

  authored and

  pnowojski

  committed
  136bb52

  Copy full SHA for 136bb52

Commits on Aug 17, 2021

• [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase

  StephanEwen

  committed
  d081d9a

  Copy full SHA for d081d9a

Commits on Aug 16, 2021

• [FLINK-23630][tests] Make EventTimeWindowCheckpointingITCase run on Windows.

  Show description for c84ebe8
  StephanEwen

  committed
  c84ebe8

  Copy full SHA for c84ebe8

• [FLINK-23629][tests] Remove redundant file-async and mem-async test runs from EventTimeWindowCheckpointingITCase

  Show description for 31b45fc
  StephanEwen

  committed
  31b45fc

  Copy full SHA for 31b45fc

• [FLINK-23767][streaming] Rename StreamStatus to WatermarkStatus.

  Show description for 474808d
  

  Arvid Heise

  authored and

  AHeise

  committed
  474808d

  Copy full SHA for 474808d

• [FLINK-23785][tests] Use unique operator names for metric tests.

  

  Arvid Heise

  authored and

  AHeise

  committed
  cab4a98

  Copy full SHA for cab4a98

Commits on Aug 15, 2021

• [FLINK-23713][tests] Harden SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted

  Show description for 1848a88
  tillrohrmann

  committed
  1848a88

  Copy full SHA for 1848a88

• [FLINK-22483][runtime] Remove CompletedCheckpointStore#recover) method an change contract of CheckpointRecoveryFactory#createCompletedCheckpointStore, so that newly constructed CheckpointStore is a…

  Show description for f64261c
  

  dmvk

  authored and

  tillrohrmann

  committed
  f64261c

  Copy full SHA for f64261c

• [FLINK-23746][tests] Harden SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

  Show description for 58abcaf
  tillrohrmann

  committed
  58abcaf

  Copy full SHA for 58abcaf

Commits on Aug 14, 2021

• [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

  

  zlzhang0122

  authored and

  pnowojski

  committed
  8463d5e

  Copy full SHA for 8463d5e

Pagination

Previous

Next