Commits

Branch selector

 master

User selector

dmvk

Datepicker

All time

Commit History

Commits on Mar 3, 2022

• [FLINK-26407][end-to-end-tests] Increase timeouts for MetricsAvailabilityITCase.

  

  dmvk

  authored and

  XComp

  committed
  26d7c09

  Copy full SHA for 26d7c09

Commits on Mar 2, 2022

• [FLINK-26286][kubernetes] Introduce idempotent KubernetesStateHandleStore.

  

  dmvk

  authored and

  XComp

  committed
  449d968

  Copy full SHA for 449d968

Commits on Mar 1, 2022

• [FLINK-26289][runtime] AdaptiveScheduler: Allow exception history to be queried by the REST API.

  

  dmvk

  authored and

  XComp

  committed
  5c4d263

  Copy full SHA for 5c4d263

Commits on Feb 17, 2022

• [FLINK-26199][table-api-java] Annotate StatementSet#compilePlan as experimental.

  Show description for fc86f13
  

  dmvk

  authored and

  twalthr

  committed
  fc86f13

  Copy full SHA for fc86f13

Commits on Feb 16, 2022

• [FLINK-26107][runtime] OperatorCoordinator uses failure handler of the current state

  dmvk

  authored
  b64a838

  Copy full SHA for b64a838

Commits on Feb 14, 2022

• [FLINK-26068] Update ZooKeeperStateHandleStore to use an indepotent replace operation for #setStateHandle, that has been introduced in CURATOR-584, to avoid possible BadVersionException during conn…

  Show description for 0cf7c3d
  

  dmvk

  authored and

  zentol

  committed
  0cf7c3d

  Copy full SHA for 0cf7c3d

• [FLINK-26067] Remove timeout on TestingContender#awaitRevokeLeadership. If the test failure repeats, we should get a full thread dump that could provide us with more context.

  

  dmvk

  authored and

  zentol

  committed
  c60eb0c

  Copy full SHA for c60eb0c

Commits on Feb 10, 2022

• [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

  

  dmvk

  authored and

  XComp

  committed
  6b17d31

  Copy full SHA for 6b17d31

• [FLINK-25755][runtime] Introduce shared state transition interfaces

  dmvk

  authored
  5180e83

  Copy full SHA for 5180e83

Commits on Feb 8, 2022

• [FLINK-26006][aws] Close AWS SDK resources

  dmvk

  authored
  fd92e56

  Copy full SHA for fd92e56

Commits on Jan 26, 2022

• [FLINK-25673][tests] Wait until all slots are freed

  dmvk

  authored
  d7bc8e2

  Copy full SHA for d7bc8e2

Commits on Jan 24, 2022

• [FLINK-25715][coordination] Allow submission of failed jobs

  Show description for 4255652
  

  dmvk

  authored and

  zentol

  committed
  4255652

  Copy full SHA for 4255652

• [FLINK-25715][runtime] Introduce TestingDispatcherGateway#newBuilder() method

  

  dmvk

  authored and

  zentol

  committed
  08f86a0

  Copy full SHA for 08f86a0

• [hotfix][docs] Regenerate config docs

  

  dmvk

  authored and

  zentol

  committed
  0b8a129

  Copy full SHA for 0b8a129

Commits on Jan 20, 2022

• [FLINK-25427] Harden the SavepointITCase.testTriggerSavepointAndResumeWithNoClaim by implicitly cloning the JobGraphs submitted into the MiniCluster.

  

  dmvk

  authored and

  dawidwys

  committed
  00856d0

  Copy full SHA for 00856d0

Commits on Jan 16, 2022

• [FLINK-24444][runtime][tests] Wait until checkpoints stopped triggering

  dmvk

  authored
  f5429e8

  Copy full SHA for f5429e8

Commits on Jan 3, 2022

• [FLINK-23946][clients] Dispatcher in application mode should be able to recover after losing and regaining leadership.

  Show description for 9247bf2
  

  dmvk

  authored and

  tillrohrmann

  committed
  9247bf2

  Copy full SHA for 9247bf2

Commits on Nov 26, 2021

• [FLINK-24789][runtime] Close CheckpointCleaner after checkpoint services in DefaultScheduler#closeAsync() and AdaptiveScheduler#closeAsync().'

  Show description for e42890f
  

  dmvk

  authored and

  tillrohrmann

  committed
  e42890f

  Copy full SHA for e42890f

• [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperStateHandleStore in case of unstable connection.

  Show description for 3d7ad08
  

  dmvk

  authored and

  tillrohrmann

  committed
  3d7ad08

  Copy full SHA for 3d7ad08

Commits on Nov 23, 2021

• [FLINK-24739][docs] Highlight the fact that the Application Mode excpects user jars to be bundled with the Flink distribution.

  

  dmvk

  authored and

  zentol

  committed
  7da7c83

  Copy full SHA for 7da7c83

• [FLINK-24739][docs] Add backreference from the deployment mode of a resource provider to the high-level deployment mode overview.

  

  dmvk

  authored and

  zentol

  committed
  6f40523

  Copy full SHA for 6f40523

Commits on Sep 17, 2021

• [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationHaveALimitedScope.

  

  dmvk

  authored and

  rmetzger

  committed
  e18d273

  Copy full SHA for e18d273

Commits on Sep 8, 2021

• [FLINK-23961][kubernetes] Hint user about missing 'kubernetes.cluster-id' config option

  dmvk

  authored
  7e91e82

  Copy full SHA for 7e91e82

Commits on Sep 6, 2021

• [FLINK-23839][kafka] Improve warnings on InvalidTxnState-/ProducerFencedException

  dmvk

  authored
  73bb9d3

  Copy full SHA for 73bb9d3

Commits on Sep 2, 2021

• [FLINK-22227][clients] Log submitted job name, id and receiving jobmanager

  dmvk

  authored
  87c0543

  Copy full SHA for 87c0543

Commits on Aug 25, 2021

• [FLINK-23908][runtime] Hint user about possibly non-deterministic shuffle key, when attemting to access out-of-the-bounds state key group.

  Show description for b09978b
  

  dmvk

  authored and

  tillrohrmann

  committed
  b09978b

  Copy full SHA for b09978b

Commits on Aug 24, 2021

• [FLINK-23840][runtime][logging] Clarify logging around CheckpointStorage

  dmvk

  authored
  658fac3

  Copy full SHA for 658fac3

• [FLINK-22221][runtime][logging] Clarify purpose of spill directories

  dmvk

  authored
  474277f

  Copy full SHA for 474277f

Commits on Aug 20, 2021

• [FLINK-21867][webui] Expose concurrent exceptions

  dmvk

  authored
  63c2a0d

  Copy full SHA for 63c2a0d

Commits on Aug 19, 2021

• [FLINK-22217][runtime][logging] Add quotes around job name

  dmvk

  authored
  16cf155

  Copy full SHA for 16cf155

Commits on Aug 15, 2021

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

Commits on Aug 13, 2021

• [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

  Show description for d9830ca
  

  dmvk

  authored and

  tillrohrmann

  committed
  d9830ca

  Copy full SHA for d9830ca

• [hotfix][k8s] Fabric8FlinkKubeClient#checkAndUpdateConfigMap lower number of indentations.

  

  dmvk

  authored and

  tillrohrmann

  committed
  20b137e

  Copy full SHA for 20b137e

Commits on Aug 11, 2021

• [FLINK-23695][runtime] Fix DispatcherFailoverITCase so it works with the AdaptiveScheduler.

  Show description for 6ded624
  

  dmvk

  authored and

  tillrohrmann

  committed
  6ded624

  Copy full SHA for 6ded624

Commits on Aug 9, 2021

• [FLINK-21979][runtime] Cleanup completed checkpoint store after dispatcher cleans up HA services.

  Show description for 1027acd
  

  dmvk

  authored and

  tillrohrmann

  committed
  1027acd

  Copy full SHA for 1027acd

Pagination

Previous

Next