Commits

Branch selector

 master

User selector

mxm

Datepicker

All time

Commit History

Commits on Apr 3, 2020

• [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

  Show description for db81417
  

  mxm

  authored and

  tillrohrmann

  committed
  db81417

Commits on Mar 16, 2020

• [FLINK-16573] Ensure Kinesis RecordFetcher threads shutdown on cancel

  Show description for 4da4432
  mxm

  committed
  4da4432

Commits on Jan 10, 2020

• [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram

  Show description for 4bb4a50
  mxm

  committed
  4bb4a50

Commits on Dec 7, 2019

• [FLINK-8949] Add dedicated watermarks metric retrieval endpoint (apache#10238)

  Show description for c1d0e99
  mxm

  authored
  c1d0e99

Commits on Dec 18, 2018

• [FLINK-11168][tests] Relax time-constraints for LargePlanTest

  Show description for 68323de
  

  mxm

  authored and

  zentol

  committed
  68323de

Commits on Dec 14, 2018

• [FLINK-10566] Fix exponential planning time of large programs

  Show description for 2870c7a
  mxm

  committed
  2870c7a

Commits on Dec 23, 2016

• [FLINK-4516] update leadership information in ResourceManager

  Show description for 66f1529
  

  mxm

  authored and

  StephanEwen

  committed
  66f1529

• [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager

  Show description for 7e9dfdf
  

  mxm

  authored and

  StephanEwen

  committed
  7e9dfdf

• [FLINK-4606] integrate features of old ResourceManager

  Show description for 9d1b5fb
  

  mxm

  authored and

  StephanEwen

  committed
  9d1b5fb

• [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses

  Show description for 7a23786
  

  mxm

  authored and

  StephanEwen

  committed
  7a23786

• [hotfix] fix ResourceManagerGateway

  

  mxm

  authored and

  StephanEwen

  committed
  0370888

• [FLINK-4535] rebase and refine

  

  mxm

  authored and

  StephanEwen

  committed
  b08e257

• [FLINK-4537] rebase and refine

  

  mxm

  authored and

  StephanEwen

  committed
  b7db70e

• [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol

  Show description for e74d5eb
  

  mxm

  authored and

  StephanEwen

  committed
  e74d5eb

Commits on Dec 16, 2016

• [FLINK-2821] use custom Akka build to listen on all interfaces

  Show description for 27ebdf7
  mxm

  committed
  27ebdf7

• [maven] properly attach the CEP Scala source code

  Show description for e9e6688
  mxm

  committed
  e9e6688

• [FLINK-5350] don't overwrite an existing JAAS config

  Show description for 0506a63
  mxm

  committed
  0506a63

• [FLINK-5091] cleanup unused Mesos configuration entries

  mxm

  committed
  becd270

• [FLINK-4922][docs] document how to use Flink on Mesos

  Show description for 9da0b0e
  mxm

  committed
  9da0b0e

• [docker] improve Dockerfile host configuration

  Show description for 6e1e139
  mxm

  committed
  6e1e139

Commits on Dec 14, 2016

• [FLINK-5240][tests] ensure state backends are properly closed

  Show description for bf2874e
  mxm

  committed
  bf2874e

Commits on Dec 7, 2016

• [docs] clarify default restart behavior when checkpointing is enabled

  mxm

  committed
  91414d9

Commits on Dec 5, 2016

• [test-utils] cleanup and improve method to set the environment

  Show description for 8d7c3ff
  mxm

  committed
  8d7c3ff

• [FLINK-5262][docs] Introduce Gemfile.lock to avoid dependency range conflicts

  Show description for 3b85f42
  mxm

  committed
  3b85f42

Commits on Nov 25, 2016

• [FLINK-5055][security] skip Hadoop UGI login if unsecured

  Show description for 1b2f3c0
  mxm

  committed
  1b2f3c0

Commits on Nov 24, 2016

• [FLINK-5149] let ContinuousEventTimeTrigger fire at the end of the window

  Show description for 2029c14
  mxm

  committed
  2029c14

Commits on Nov 21, 2016

• [FLINK-5071][yarn] adjust vcore validation check

  Show description for 5836f7e
  mxm

  committed
  5836f7e

Commits on Nov 4, 2016

• [FLINK-3813][yarn] wait for CLI to complete before checking output

  Show description for e480762
  mxm

  committed
  e480762

• [FLINK-4998][yarn] fail if too many task slots are configured

  Show description for 1c0c668
  mxm

  committed
  1c0c668

Commits on Nov 3, 2016

• [yarn] fix debug string displayed for failed applications

  Show description for bb26c9e
  mxm

  committed
  bb26c9e

Commits on Oct 27, 2016

• [FLINK-4913][yarn] include user jars in system class loader

  Show description for 2b600d3
  mxm

  committed
  2b600d3

Commits on Oct 21, 2016

• [FLINK-4833] properly log exceptions in CountMinHeavyHitter

  Show description for a27451d
  mxm

  committed
  a27451d

Commits on Oct 18, 2016

• [FLINK-4829] snapshot accumulators on a best-effort basis

  Show description for d95929e
  mxm

  committed
  d95929e

• [FLINK-4829] protect user accumulators against concurrent updates

  mxm

  committed
  783dca5

Commits on Oct 14, 2016

• [FLINK-4667] add import for config entry

  mxm

  committed
  a2e999b

Pagination

PreviousNext