- 04 1月, 2015 1 次提交
-
-
由 Gyula Fora 提交于
-
- 03 1月, 2015 16 次提交
-
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
Conflicts: flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
[scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
- 20 12月, 2014 1 次提交
-
-
由 mbalassi 提交于
Removed Disclaimer file Eliminated unnecessary incubating substrings Bumped version to 0.9-SNAPSHOT
-
- 19 12月, 2014 22 次提交
-
-
由 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.
-