8000 Commits · ivanliu/flink · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Nov 16, 2016

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

tillrohrmann
authored and
StephanEwen
committed

Commits on Nov 15, 2016

[hotfix] Remove unused ProcessingTimeService from Evictor
tillrohrmann
committed

Commits on Nov 10, 2016

[FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor information
tillrohrmann
committed
[FLINK-5033] [cep] Advance time with incoming watermarks at CEP operator
tillrohrmann
committed

Commits on Nov 9, 2016

[hotfix] Move logging of JobStatus changes into the ExecutionGraph
tillrohrmann
committed

Commits on Nov 8, 2016

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

tillrohrmann
authored and
StephanEwen
committed

Commits on Nov 1, 2016

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

Commits on Oct 31, 2016

Commits on Oct 28, 2016

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

Commits on Oct 27, 2016

Commits on Oct 20, 2016

[FLINK-4857] Remove throws clause from ZooKeeperUtils functions
tillrohrmann
committed

Commits on Oct 6, 2016

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

Commits on Sep 30, 2016

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

Commits on Sep 27, 2016

Commits on Sep 26, 2016

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

Commits on Sep 8, 2016

Commits on Sep 2, 2016

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

Commits on Sep 1, 2016

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

Commits on Aug 31, 2016

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

tillrohrmann
authored and
aljoscha
committed
[FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

tillrohrmann
authored and
aljoscha
committed

Commits on Aug 19, 2016

[FLINK-3319] [cep] Add documentation for or function
tillrohrmann
committed

Commits on Aug 1, 2016

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

tillrohrmann
authored and
uce
committed

Commits on Jul 26, 2016

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

tillrohrmann
authored and
mxm
committed

Commits on Jul 22, 2016

[FLINK-4202] [metrics] Update restarting time metric documentation
tillrohrmann
committed

Commits on Jul 21, 2016

[FLINK-4202] Add restarting time JM metric
tillrohrmann
committed

Commits on Jul 15, 2016

Commits on Jul 13, 2016

[FLINK-4167] [metrics] Make IOMetricGroup register its metrics at the parent metric group
tillrohrmann
committed

Commits on Jul 12, 2016

0