- 19 12月, 2014 40 次提交
-
-
由 Gyula Fora 提交于
-
由 Jonas Traub (powibol) 提交于
[streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. [streaming] Changed TimeEvictionPolicy to keep timestamps in the buffer instead of data-items
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
Excluded the scala example jars Excluded the example source code subdirectories This closes #274
-
由 Gyula Fora 提交于
-
由 Till Rohrmann 提交于
Let the submitJobAndWait method check continuously whether the job manager is still alive. Terminate waiting for a response in case of a job manager outage.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Fix race condition in ExecutionGraph which made the job finish before all vertices have called the finalizeOnMaster method.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Use Akka version 2.2.1 for hadoop version 2.0.0-alpha to resolve dependency conflicts. Adjust code to comply to respective Akka API. Remove obsolete TODO.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Add option to use single actor system for local execution. Use local connection manager if a single task manager is used for local execution. Remove synchronized blcok in getReceiverList of ChannelManager which effectively serialized the connection lookup calls of a single task manager. Fix Java6 problem that File has no method toPath
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Made ExecutionGraph, Execution, ExecutionJobVertex, ExecutionVertex, AllocatedSlot, Instance, CoLocationConstraint, SharedSlot and SlotSharingGroupAssignment serializable. Integrated Kryo to be used to serialize Akka messages.
-
由 Till Rohrmann 提交于
Removed dead instance cleanup from InstanceManager so that Akka's watch mechanism is the current mean to detect dead instances.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
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 ForkableFlinkMiniCluster for test execution.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Reworked local cluster start. TaskManager watches JobManager and tries reregistration in case of disconnect. Introduced akka.ask.timeout config parameter to configure akka timeouts.
-
由 Till Rohrmann 提交于
Fixed ExecutionVertexCancelTest after removing submitTask and cancelTask.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Removed old events. Adapted webserver communication so that it can now talk to the actor implementations.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Removed old java implementations of the JobManager, TaskManager, JobClient, EventCollector, TaskOperationResult and MemoryArchivist.
-
由 Till Rohrmann 提交于
-