Conflicts:
	flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala

[scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs

Removed Disclaimer file
Eliminated unnecessary incubating substrings
Bumped version to 0.9-SNAPSHOT

[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

Excluded the scala example jars
Excluded the example source code subdirectories

This closes #274

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.

Fix race condition in ExecutionGraph which made the job finish before all vertices have called the finalizeOnMaster method.

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.

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

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

Made ExecutionGraph, Execution, ExecutionJobVertex, ExecutionVertex, AllocatedSlot, Instance, CoLocationConstraint, SharedSlot and SlotSharingGroupAssignment serializable. Integrated Kryo to be used to serialize Akka messages.

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

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.

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

Fixed ExecutionVertexCancelTest after removing submitTask and cancelTask.