Commits

Branch selector

 master

User selector

tillrohrmann

Datepicker

All time

Commit History

Commits on Nov 30, 2016

• [FLINK-5197] [jm] Ignore outdated JobStatusChanged messages

  Show description for ae0975c
  tillrohrmann

  committed
  ae0975c

  Copy full SHA for ae0975c

Commits on Nov 27, 2016

• [FLINK-5112] [ExecutionGraph] Remove unused accumulator aggregation code from ArchivedExecutionJobVertex

  Show description for 2eacfba
  

  tillrohrmann

  authored and

  zentol

  committed
  2eacfba

  Copy full SHA for 2eacfba

Commits on Nov 23, 2016

• [FLINK-5010] [akka] Introduce default configuration values for Akka's deathwatch

  Show description for 3e3a90d
  tillrohrmann

  committed
  3e3a90d

  Copy full SHA for 3e3a90d

Commits on Nov 22, 2016

• [FLINK-5107] Handle evicted execution attempts in request handlers

  Show description for 4c23879
  tillrohrmann

  committed
  4c23879

  Copy full SHA for 4c23879

• [FLINK-5085] Execute CheckpointCoordinator's state discard calls asynchronously

  Show description for c590912
  tillrohrmann

  committed
  c590912

  Copy full SHA for c590912

• [FLINK-5073] Use Executor to run ZooKeeper callbacks in ZooKeeperStateHandleStore

  Show description for 3fb92d8
  tillrohrmann

  committed
  3fb92d8

  Copy full SHA for 3fb92d8

• [FLINK-5082] Pull ExecutorService lifecycle management out of the JobManager

  Show description for ae4b274
  tillrohrmann

  committed
  ae4b274

  Copy full SHA for ae4b274

Commits on Nov 16, 2016

• [FLINK-5063] [checkpointing] Discard state handles of declined or expired state handles

  Show description for 72b295b
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  72b295b

  Copy full SHA for 72b295b

Commits on Nov 15, 2016

• [hotfix] Remove unused ProcessingTimeService from Evictor

  tillrohrmann

  committed
  5845d29

  Copy full SHA for 5845d29

Commits on Nov 10, 2016

• [FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor information

  Show description for 58204da
  tillrohrmann

  committed
  58204da

  Copy full SHA for 58204da

• [FLINK-5033] [cep] Advance time with incoming watermarks at CEP operator

  Show description for 029fda2
  tillrohrmann

  committed
  029fda2

  Copy full SHA for 029fda2

Commits on Nov 9, 2016

• [hotfix] Move logging of JobStatus changes into the ExecutionGraph

  Show description for 7a51895
  tillrohrmann

  committed
  7a51895

  Copy full SHA for 7a51895

Commits on Nov 8, 2016

• [FLINK-5022] Suppress RejectedExecutionExceptions if the ExecutorService has been shut down

  Show description for d390824
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  d390824

  Copy full SHA for d390824

Commits on Nov 1, 2016

• [FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate communcation logic

  Show description for cfb3790
  tillrohrmann

  committed
  cfb3790

  Copy full SHA for cfb3790

Commits on Oct 31, 2016

• [FLINK-4933] [exec graph] Don't let the EG fail in case of a failing scheduleOrUpdateConsumers call

  Show description for 1574249
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  1574249

  Copy full SHA for 1574249

• [FLINK-4932] [distributed coordination] Failing in state RESTARTING only fails terminally if no more restarts are possible

  Show description for 18507de
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  18507de

  Copy full SHA for 18507de

Commits on Oct 28, 2016

• [hotfix] [docs] Add documentation for TaskManager's registration configuration parameters

  tillrohrmann

  committed
  211f5db

  Copy full SHA for 211f5db

Commits on Oct 27, 2016

• [FLINK-4889] [InstanceManager] Remove ActorRef dependency from InstanceManager

  Show description for 09ff410
  tillrohrmann

  committed
  09ff410

  Copy full SHA for 09ff410

• [FLINK-4903] [futures] Introduce synchronous future operations

  Show description for 1e1e4dc
  tillrohrmann

  committed
  1e1e4dc

  Copy full SHA for 1e1e4dc

Commits on Oct 20, 2016

• [FLINK-4857] Remove throws clause from ZooKeeperUtils functions

  Show description for 6f0faf9
  tillrohrmann

  committed
  6f0faf9

  Copy full SHA for 6f0faf9

Commits on Oct 6, 2016

• [FLINK-4751] [futures] Add thenCombineAsync function to Flink's futures

  Show description for 98710ea
  tillrohrmann

  committed
  98710ea

  Copy full SHA for 98710ea

Commits on Sep 30, 2016

• [FLINK-4711] Let the Task trigger partition state requests and handle their responses

  Show description for 477d1c5
  tillrohrmann

  committed
  477d1c5

  Copy full SHA for 477d1c5

Commits on Sep 27, 2016

• [FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate MetricRegistry parameters

  Show description for f1b5b35
  tillrohrmann

  committed
  f1b5b35

  Copy full SHA for f1b5b35

• [FLINK-4690] Use direct executor to run slot allocation future handler

  tillrohrmann

  committed
  84672c2

  Copy full SHA for 84672c2

• [FLINK-4361] Introduce Flink's own future abstraction

  Show description for f8138f4
  tillrohrmann

  committed
  f8138f4

  Copy full SHA for f8138f4

Commits on Sep 26, 2016

• [hotfix] Fix restart strategy class loading by using not lower cased class name

  tillrohrmann

  committed
  28ff5a3

  Copy full SHA for 28ff5a3

Commits on Sep 8, 2016

• [FLINK-4456] Replace Akka specific types by interfaces in Task

  Show description for 0735b5b
  tillrohrmann

  committed
  0735b5b

  Copy full SHA for 0735b5b

• [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster

  Show description for 02b852e
  tillrohrmann

  committed
  02b852e

  Copy full SHA for 02b852e

Commits on Sep 2, 2016

• [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnvironment independent of ActorGateway and JobManager association

  Show description for 78f2a15
  tillrohrmann

  committed
  78f2a15

  Copy full SHA for 78f2a15

Commits on Sep 1, 2016

• [hotfix] [test-stability] Properly fail if ZooKeeperTestEnvironment cannot delete ZNodes

  tillrohrmann

  committed
  cb89ba1

  Copy full SHA for cb89ba1

Commits on Aug 31, 2016

• [FLINK-4380] Add tests for new Key-Group/Max-Parallelism

  Show description for 516ad01
  

  tillrohrmann

  authored and

  aljoscha

  committed
  516ad01

  Copy full SHA for 516ad01

• [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

  Show description for ec975aa
  

  tillrohrmann

  authored and

  aljoscha

  committed
  ec975aa

  Copy full SHA for ec975aa

Commits on Aug 19, 2016

• [FLINK-3319] [cep] Add documentation for or function

  tillrohrmann

  committed
  f0fef6f

  Copy full SHA for f0fef6f

Commits on Aug 1, 2016

• [FLINK-4296] Fixes failure reporting of consumer task scheduling when producer has already finished

  Show description for 10642f7
  

  tillrohrmann

  authored and

  uce

  committed
  10642f7

  Copy full SHA for 10642f7

Commits on Jul 26, 2016

• [FLINK-4152] Allow re-registration of TMs at resource manager

  Show description for 2648bc1
  

  tillrohrmann

  authored and

  mxm

  committed
  2648bc1

  Copy full SHA for 2648bc1

Pagination

Previous

Next