Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 23, 2015

• [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN

  Show description for 2af6586
  rmetzger

  committed
  2af6586

  Copy full SHA for 2af6586

Commits on Jan 21, 2015

• [runtime] Add spillable input deserializer

  

  StephanEwen

  authored and

  uce

  committed
  be8e1f1

  Copy full SHA for be8e1f1

Commits on Jan 20, 2015

• [FLINK-1372] [runtime] Fixes logging settings. The logging is now exclusively controlled by the logging properties provided to the system. Removes akka.loglevel config parameter.

  

  tillrohrmann

  authored and

  uce

  committed
  4e197d5

  Copy full SHA for 4e197d5

Commits on Jan 19, 2015

• FLINK-1420 Small cleanup on code after branch for 0.8 release

  Show description for 58e1e44
  hsaputra

  committed
  58e1e44

  Copy full SHA for 58e1e44

• [FLINK-1395] Add tests for custom serializers with JodaTime.

  

  aljoscha

  authored and

  StephanEwen

  committed
  020b282

  Copy full SHA for 020b282

Commits on Jan 12, 2015

• [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results

  Show description for d908ca1
  uce

  committed
  d908ca1

  Copy full SHA for d908ca1

Commits on Jan 11, 2015

• [FLINK-1378] Add support for Throwables in KryoSerializer

  

  aljoscha

  authored and

  StephanEwen

  committed
  8af6ef4

  Copy full SHA for 8af6ef4

Commits on Jan 8, 2015

• [FLINK-333] [apis] Forward crossWithSmall and crossWithLarge hints to optimizer.

  StephanEwen

  committed
  0954c4e

  Copy full SHA for 0954c4e

• [FLINK-1266] More dependency exclusions & fixed image in web client

  Show description for 39fb7c9
  rmetzger

  committed
  39fb7c9

  Copy full SHA for 39fb7c9

• [FLINK-1266] Update mongodb link and address pull request comments

  rmetzger

  committed
  0af4d3a

  Copy full SHA for 0af4d3a

• [FLINK-1266] Generalize DistributedFileSystem implementation

  Show description for f290929
  rmetzger

  committed
  f290929

  Copy full SHA for f290929

• [FLINK-1245] [Java API] Introduce TypeHints for Java API operators

  Show description for d8dbaee
  

  twalthr

  authored and

  StephanEwen

  committed
  d8dbaee

  Copy full SHA for d8dbaee

Commits on Jan 7, 2015

• [FLINK-1285] Various cleanup of object reusing and non-reusing code.

  Show description for 26c9819
  StephanEwen

  committed
  26c9819

  Copy full SHA for 26c9819

• [FLINK-1285] Make execution mode configurable

  

  aljoscha

  authored and

  StephanEwen

  committed
  b7b32a0

  Copy full SHA for b7b32a0

• [FLINK-1137] Enhance MutableObjectIterator with non-reuse next()

  Show description for 3832d7b
  

  aljoscha

  authored and

  StephanEwen

  committed
  3832d7b

  Copy full SHA for 3832d7b

Commits on Jan 6, 2015

• [FLINK-1169] [apis] Add documentation for join hints.

  StephanEwen

  committed
  c52f4ca

  Copy full SHA for c52f4ca

• [FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements.

  StephanEwen

  committed
  e71ee0b

  Copy full SHA for e71ee0b

• [FLINK-1300] [core] Remove unused and redundant files DataInputViewStream and DataOutputViewStream.

  StephanEwen

  committed
  875c6aa

  Copy full SHA for 875c6aa

• [FLINK-1349] [runtime] Various fixes concerning Akka

  Show description for 972a7b0
  StephanEwen

  committed
  972a7b0

  Copy full SHA for 972a7b0

Commits on Dec 20, 2014

• [FLINK-1338] Updates necessary due to Apache graduation

  Show description for 561eaf0
  mbalassi

  committed
  561eaf0

  Copy full SHA for 561eaf0

Commits on Dec 18, 2014

• Execute lookupConnectionInformation and UpdateTaskExecutionState concurrently within futures

  tillrohrmann

  committed
  0516d26

  Copy full SHA for 0516d26

• Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout.

  tillrohrmann

  committed
  1cd44e0

  Copy full SHA for 1cd44e0

• Add debug guardians to suppress string generation which caused a significant performance loss.

  tillrohrmann

  committed
  dd9a1ba

  Copy full SHA for dd9a1ba

• Made ExecutionGraph, Execution, ExecutionJobVertex, ExecutionVertex, AllocatedSlot, Instance, CoLocationConstraint, SharedSlot and SlotSharingGroupAssignment serializable. Integrated Kryo to be use…

  Show description for f726e55
  tillrohrmann

  committed
  f726e55

  Copy full SHA for f726e55

• Removed dead instance cleanup from InstanceManager so that Akka's watch mechanism is the current mean to detect dead instances.

  tillrohrmann

  committed
  8d414d7

  Copy full SHA for 8d414d7

• Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use Forkable…

  Show description for c175ebe
  tillrohrmann

  committed
  c175ebe

  Copy full SHA for c175ebe

• Adapted test cases to actor model after rebasing.

  tillrohrmann

  committed
  bd4ee47

  Copy full SHA for bd4ee47

• Reworked local cluster start. TaskManager watches JobManager and tries reregistration in case of disconnect. Introduced akka.ask.timeout config parameter to configure akka timeouts.

  tillrohrmann

  committed
  b8d0a0a

  Copy full SHA for b8d0a0a

• Removed submitTask and cancelTask from Instance. Replaced unnecessary blocking calls.

  Show description for 26c7794
  tillrohrmann

  committed
  26c7794

  Copy full SHA for 26c7794

• Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory.

  tillrohrmann

  committed
  76d603c

  Copy full SHA for 76d603c

• Reworked Yarn client: Actor based communication.

  tillrohrmann

  committed
  5a192bd

  Copy full SHA for 5a192bd

• Added AKKA_LOG_LEVEL config constant.

  tillrohrmann

  committed
  f96bca0

  Copy full SHA for f96bca0

• Replaced the JobClient by an actor.

  tillrohrmann

  committed
  241c1ca

  Copy full SHA for 241c1ca

• Removed execution service from execution graph and replaced by akka's futures.

  tillrohrmann

  committed
  ac94253

  Copy full SHA for ac94253

• Updated license headers of scala files to conform to scala-checkstyle.

  tillrohrmann

  committed
  b1cb66f

  Copy full SHA for b1cb66f

Pagination

Previous

Next