Commits

History for

Commits on Sep 30, 2015

[FLINK-2703] Prepare Flink for being used with Logback.
rmetzger
committedSep 30, 2015

Commits on Sep 29, 2015

[FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes
hsaputra
committedSep 29, 2015

Commits on Sep 22, 2015

[FLINK-2097][core] implement a job session management
mxm
committedSep 22, 2015
[FLINK-2722] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname
rmetzger
committedSep 22, 2015

Commits on Sep 17, 2015

[FLINK-2640] [yarn] integrate off-heap configuration

mxm
authored and
fhueske
committedSep 17, 2015

Commits on Sep 9, 2015

[FLINK-2392] Improve YARN test stability
rmetzger
committedSep 9, 2015

Commits on Sep 8, 2015

[FLINK-1320] [core] Add an off-heap variant of the managed memory
StephanEwen
committedSep 8, 2015

Commits on Aug 31, 2015

[FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers.
tillrohrmann
committedAug 31, 2015

Commits on Aug 27, 2015

[FLINK-2326] [yarn] Write yarn properties file to temp directory

rmetzger
authored and
StephanEwen
committedAug 27, 2015

Commits on Aug 12, 2015

[CLEANUP] Add space between quotes and plus sign in String concat for readability in flink-yarn module
hsaputra
committedAug 12, 2015

Commits on Aug 3, 2015

[FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web server to automatically decorate messages with a leader session ID.
tillrohrmann
committedAug 3, 2015

Commits on Jul 23, 2015

[FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.
tillrohrmann
committedJul 23, 2015

Commits on Jul 15, 2015

[FLINK-2292][FLINK-1573] add live per-task accumulators
mxm
committedJul 15, 2015

Commits on Jul 13, 2015

[FLINK-2329] [runtime] Introduces InstanceGateway as an abstraction to communicate with the TaskManager.

tillrohrmann
authored and
StephanEwen
committedJul 13, 2015

Commits on Jul 1, 2015

[FLINK-2298] Add option to pass a custom name for Flink on YARN
rmetzger
committedJul 1, 2015

Commits on Jun 16, 2015

[FLINK-2226][YARN] fail application on failed single-job cluster job
mxm
committedJun 16, 2015

Commits on Jun 7, 2015

[FLINK-2087] Add streaming mode switch to YARN
rmetzger
committedJun 7, 2015

Commits on May 27, 2015

[yarn] Adjust default values for YARN heap memory cutoff
rmetzger
committedMay 27, 2015
[FLINK-2079] Add TaskManager deathwatch thread for YARN case
rmetzger
committedMay 27, 2015

Commits on May 26, 2015

[tests] Adjust tests for dedicated streaming mode and clean up test bases.
StephanEwen
committedMay 26, 2015
[FLINK-1920] Properly pass command line arguments with spaces to Flink
rmetzger
committedMay 26, 2015

Commits on May 22, 2015

Commits on May 11, 2015

[FLINK-1969] [runtime] Remove deprecated profiler code
StephanEwen
committedMay 11, 2015

Commits on Apr 29, 2015

[FLINK-1923] [runtime] Replaces asynchronous logging with synchronous logging using grizzled-slf4j wrapper for Scala.

tillrohrmann
authored and
StephanEwen
committedApr 29, 2015

Commits on Apr 28, 2015

Commits on Apr 17, 2015

[FLINK-1902] Show jobmanager address/port in configuration
rmetzger
committedApr 17, 2015

Commits on Apr 6, 2015

[FLINK-1580] [taskmanager] Improve TaskManager startup robustness
StephanEwen
committedApr 6, 2015

Commits on Mar 31, 2015

[FLINK-1771] Add support for submitting single jobs to a detached YARN session
rmetzger
committedMar 31, 2015

Commits on Mar 27, 2015

[FLINK-1650] Let Netty(Akka) use Slf4j
rmetzger
committedMar 27, 2015

Commits on Mar 23, 2015

[FLINK-1679] use a consistent name for parallelism
mxm
committedMar 23, 2015

Commits on Mar 20, 2015

Small changes to make code more consistent.
hsaputra
committedMar 20, 2015

Commits on Mar 19, 2015

[yarn] Add final modifier to PollingThread#lock object to make sure immutability.

hsaputra
authored and
StephanEwen
committedMar 19, 2015

Commits on Mar 12, 2015

[FLINK-1629][FLINK-1630][FLINK-1547] Add option to start Flink on YARN in a detached mode. YARN container reallocation.
rmetzger
committedMar 12, 2015