Commits

Branch selector

 master

User selector

mxm

Datepicker

All time

Commit History

Commits on Jan 2, 2023

• Update flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java

  Show description for 1c2f4eb
  

  2 peopleauthored and

  gyfora

  committed
  1c2f4eb

• PR comment

  Show description for 41518d6
  

  2 peopleauthored and

  gyfora

  committed
  41518d6

• Use RebalancePartitioner

  

  mxm

  authored and

  gyfora

  committed
  d20533e

• Replace Java 11 call

  

  mxm

  authored and

  gyfora

  committed
  3b1288e

• [FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes

  Show description for 61d6e78
  

  mxm

  authored and

  gyfora

  committed
  61d6e78

Commits on Nov 23, 2022

• [FLINK-29501] Add option to override job vertex parallelisms during job submission (apache#21023)

  Show description for 23ce228
  mxm

  authored
  23ce228

Commits on Sep 14, 2022

• [FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests

  mxm

  committed
  0612a99

Commits on Aug 7, 2020

• [FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

  Show description for 182be51
  

  mxm

  authored and

  tillrohrmann

  committed
  182be51

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

Pagination

PreviousNext