Commits

Branch selector

 master

User selector

XComp

Datepicker

All time

Commit History

Commits on Aug 31, 2023

• [FLINK-32994][runtime] Adds proper toString() implementations to the LeaderElectionDriver implementations to have human-readable versions of the driver in log messages

  XComp

  committed
  11259ef

  Copy full SHA for 11259ef

Commits on Aug 30, 2023

• [FLINK-32751][streaming] Fixes bug where the enqueued requests are not properly cancelled

  XComp

  committed
  5b8c4a7

  Copy full SHA for 5b8c4a7

• [FLINK-32751][streaming] Refactors CollectSinkOperatorCoordinator to improve its testability

  Show description for d343a0b
  XComp

  committed
  d343a0b

  Copy full SHA for d343a0b

• [hotfix][JUnit5] Migrates CollectSinkOperatorCoordinatorTest to JUnit5 and Assertj

  XComp

  committed
  ef9e490

  Copy full SHA for ef9e490

• [hotfix][test] Refactors test to remove version and offset server-side checks

  Show description for c693041
  XComp

  committed
  c693041

  Copy full SHA for c693041

Commits on Aug 21, 2023

• [FLINK-32751][runtime] Refactors CollectSinkOperatorCoordinator to enable case-specific logging

  Show description for b5b1340
  XComp

  committed
  b5b1340

  Copy full SHA for b5b1340

• [hotfix][test] Migrates RestClientTest to JUnit5/AssertJ

  XComp

  committed
  1c76850

  Copy full SHA for 1c76850

Commits on Aug 3, 2023

• [FLINK-32734][build] Adds .mvn/maven.config to .gitignore

  Show description for 93da795
  XComp

  committed
  93da795

  Copy full SHA for 93da795

Commits on Aug 2, 2023

• [FLINK-32662][test] Fixes JobMasterTest#testRetrievingCheckpointStats with the AdaptiveScheduler

  Show description for 74babda
  XComp

  committed
  74babda

  Copy full SHA for 74babda

• [FLINK-32715][test] Make test wait for application to stop before shutting down the other services (apache#23104)

  XComp

  authored
  99b9833

  Copy full SHA for 99b9833

• [hotfix][test] Removes error handling

  Show description for 2a1ae11
  XComp

  committed
  2a1ae11

  Copy full SHA for 2a1ae11

• [FLINK-31168][test] Makes TestJvmProcess.destroy() wait for the process to actually go away

  XComp

  committed
  476d688

  Copy full SHA for 476d688

Commits on Aug 1, 2023

• Revert "[FLINK-32223][runtime][security] Add Hive delegation token support"

  Show description for 8386ef5
  XComp

  committed
  8386ef5

  Copy full SHA for 8386ef5

Commits on Jul 23, 2023

• [FLINK-32632][test] Downloads binaries for cri-dockerd to avoid building the binaries using Go

  Show description for bc964a1
  XComp

  committed
  bc964a1

  Copy full SHA for bc964a1

• [hotfix][test] Introduces local variables for cri-dockerd version

  Show description for 17f1d2d
  XComp

  committed
  17f1d2d

  Copy full SHA for 17f1d2d

• [hotfix][test] Makes wget calls less verbose

  Show description for d95a64e
  XComp

  committed
  d95a64e

  Copy full SHA for d95a64e

Commits on Jul 10, 2023

• [FLINK-32556][runtime] Renames contenderID into componentId (apache#22967)

  Show description for 773feeb
  XComp

  authored
  773feeb

  Copy full SHA for 773feeb

Commits on Jul 9, 2023

• [hotfix][runtime] Removes unused members and fixed typo

  Show description for 9a4119f
  XComp

  committed
  9a4119f

  Copy full SHA for 9a4119f

• [hotfix][tests] Adds proper multi-threading to the test case

  Show description for e65b12e
  XComp

  committed
  e65b12e

  Copy full SHA for e65b12e

• [FLINK-31837] Makes the driver instantiation being performed lazily as soon as the first contender is registered

  Show description for d2e6b94
  XComp

  committed
  d2e6b94

  Copy full SHA for d2e6b94

Commits on Jul 7, 2023

• [hotfix][test] Removes unused ClusterComponent enum

  Show description for ffe7b07
  XComp

  committed
  ffe7b07

  Copy full SHA for ffe7b07

• [FLINK-32381][runtime] Replaces FatalErrorHandler in LeaderElectionDriver with LeaderElectionDriver.Listener#onError interface method

  Show description for 174cf25
  XComp

  committed
  174cf25

  Copy full SHA for 174cf25

• [hotfix][tests] Adds error handling to ZK-related DefaultLeaderElectionService tests

  Show description for af75268
  XComp

  committed
  af75268

  Copy full SHA for af75268

• [hotfix][runtime] Removes obsolete Precondition (the executorService is final and set within the constructor)

  Show description for e31ecb9
  XComp

  committed
  e31ecb9

  Copy full SHA for e31ecb9

• [FLINK-31814][runtime] Enables Precondition that checks that the issuedLeaderSessionID is set on revoke processing

  Show description for c5fc723
  XComp

  committed
  c5fc723

  Copy full SHA for c5fc723

Commits on Jul 6, 2023

• [FLINK-32419][runtime] Renames leader election related classes/fields/methods

  Show description for df2747f
  XComp

  committed
  df2747f

  Copy full SHA for df2747f

• [FLINK-32419][runtime] Deletes obsolete/unused leader election related classes

  Show description for 716aa11
  XComp

  committed
  716aa11

  Copy full SHA for 716aa11

• [hotfix][runtime] Adds shutdown logic for the watchExecutorService to the k8s HA services

  Show description for 08d0e6b
  XComp

  committed
  08d0e6b

  Copy full SHA for 08d0e6b

• [hotfix][runtime] Reorganizes ZooKeeperUtils

  Show description for a46cf26
  XComp

  committed
  a46cf26

  Copy full SHA for a46cf26

• [FLINK-32409][runtime] Removes MultipleComponentLeaderElectionService dependency

  Show description for e35a236
  XComp

  committed
  e35a236

  Copy full SHA for e35a236

Commits on Jul 5, 2023

• [hotfix][test] Migrates EmbeddedLeaderServiceTest to JUnit5/AssertJ

  Show description for e56e87e
  XComp

  committed
  e56e87e

  Copy full SHA for e56e87e

• [FLINK-32421][test] Fixes testConcurrentRevokeLeadershipAndShutdown to test the actual functionality consistently

  Show description for 5dbbc69
  XComp

  committed
  5dbbc69

  Copy full SHA for 5dbbc69

Commits on Jul 4, 2023

• [FLINK-31784][runtime] Adds multi-component support to DefaultLeaderElectionService

  Show description for db4b594
  XComp

  committed
  db4b594

  Copy full SHA for db4b594

• [hotfix][runtime] Adds JavaDoc and tests besides adding some additional utility methods

  Show description for b60c154
  XComp

  committed
  b60c154

  Copy full SHA for b60c154

• [hotfix][test] Makes DefaultLeaderElectionService being instantiated within the try context

  Show description for 0c37b5e
  XComp

  committed
  0c37b5e

  Copy full SHA for 0c37b5e

Pagination

Previous

Next