GitHub user msdevanms opened a pull request:
https://github.com/apache/flink/pull/312
https://issues.apache.org/jira/browse/FLINK-1388
https://issues.apache.org/jira/browse/FLINK-1388
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/flink release-0.8
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/312.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #312
----
commit a33ad5d8303295e57f0e6a8df3c071f010963029
Author: mbalassi <[email protected]>
Date: 2014-12-16T11:48:09Z
[streaming] DataStream print functionality update
PrintSinkFunction now explicitly states threads in output
Added printToErr functionality
commit e34aca7545f4900725b470ff1ab2db4b48c2275f
Author: mbalassi <[email protected]>
Date: 2014-12-16T20:00:31Z
[streaming] [examples] Refactor and packaging for windowing examples
The current examples show-case the API, more meaningful examples are coming
for the 0.9 release.
commit c8e306b6567a4b615c54e8d8f88116ff6f1a0e38
Author: Gyula Fora <[email protected]>
Date: 2014-12-16T21:49:58Z
[streaming] Updated deprecated iterative functionality and docs
commit 1ac9651abff2760a2a66c6cce0e3aa2e1bf5d1dd
Author: twalthr <[email protected]>
Date: 2014-12-10T21:02:07Z
Fix invalid type hierarchy creation by Pojo logic
commit a835e5dfb97624f3132761c7933aaffb03b0d06f
Author: Robert Metzger <[email protected]>
Date: 2014-12-16T10:30:52Z
[FLINK-610] Replace Avro by Kryo as the GenericType serializer
The performance of data-intensive jobs using Kryo is probably going to be
slow.
Set correct classloader
try to use Kryo.copy() with fallback to serialization copy
commit 7ef04c625768515c874f3b015cf30f6631c4dade
Author: Robert Metzger <[email protected]>
Date: 2014-12-16T21:00:50Z
[FLINK-1333] Fixed getter/setter recognition for POJOs
This closes #271
commit 02bad15318da525f6db938a41cd10c7203156314
Author: mbalassi <[email protected]>
Date: 2014-12-17T15:46:01Z
[FLINK-1325] [streaming] Added clousure cleaning to streaming
This closes #273
commit 6f481ce785b9d4a9824b9d7c82e18342bbeaf897
Author: Till Rohrmann <[email protected]>
Date: 2014-12-18T10:37:23Z
Fixes race condition in ExecutionGraph which allowed a job to go into the
finished state without all job vertices having properly processed the
finalizeOnMaster method.
commit 15fb1da9907cc549ddb94f191fba11618f546854
Author: Stephan Ewen <[email protected]>
Date: 2014-12-18T14:28:54Z
[FLINK-1336] [core] Fix bug in StringValue binary copy method
commit 88f38e49202354926cb4ec36390cbe34bad247a3
Author: Gyula Fora <[email protected]>
Date: 2014-12-17T22:34:26Z
[streaming] StreamInvokable rework for simpler logic and easier use
commit 2ac49856ac8a3aa42912b1e74a7109792c5b93aa
Author: mbalassi <[email protected]>
Date: 2014-12-17T23:28:07Z
[dist] Updated the assembly of the examples subdirectory
Excluded the scala example jars
Excluded the example source code subdirectories
This closes #274
commit 446cc1253554f924664d7fe753f3cee46ee87c13
Author: Gyula Fora <[email protected]>
Date: 2014-12-18T13:52:15Z
[streaming] Added immutability for window and filter operators
commit cadc9cce0bbfa2615ed746a6b0372f21e042a945
Author: Jonas Traub (powibol) <[email protected]>
Date: 2014-12-18T15:11:16Z
[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
commit 9555c827f8b354722f6865d531f3fccd400c0015
Author: mbalassi <[email protected]>
Date: 2014-12-19T22:34:02Z
[FLINK-1338] Updates necessary due to Apache graduation
Removed Disclaimer file
Eliminated unnecessary incubating substrings
Bumped version to 0.8-SNAPSHOT
commit 6b3c3a1780b1270226a76f6a81a9ad2029578a7a
Author: mbalassi <[email protected]>
Date: 2014-12-26T17:02:55Z
[FLINK-1225] Fix for quickstart packaging
This closes #279
commit 2467f36c80830e83b43271c89cf1ec827882b424
Author: mbalassi <[email protected]>
Date: 2014-12-26T17:06:51Z
[streaming] Temporal fix for streaming source parallelism
commit b2271bd9eb3adc1770f40d452ed7fb69614ea649
Author: Gyula Fora <[email protected]>
Date: 2015-01-02T17:33:46Z
[streaming] Time trigger preNotify fix
commit 6b1fd156a774a8292dd2e9227d611dcca5b9c526
Author: Gyula Fora <[email protected]>
Date: 2014-12-11T14:22:03Z
[scala] [streaming] Base functionality added for streaming scala api
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
commit 40efecf7cf79deb02f070bedc9980c91886b66ef
Author: Gyula Fora <[email protected]>
Date: 2014-12-11T23:12:49Z
[scala] [streaming] Extended scala data stream functionality to include
simple operators
commit d1b53b16695231f54d912d847c11a406523c8d5b
Author: Gyula Fora <[email protected]>
Date: 2014-12-13T00:08:08Z
[scala] [streaming] Finished scala StreamExecutionEnvrionment functionality
+ DataStream sinks + docs
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsCsvTest.java
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsTextTest.java
commit e0ab48988d22ba2a38a8e6e43d9ede6215fdddb5
Author: Gyula Fora <[email protected]>
Date: 2014-12-15T15:21:00Z
[scala] [streaming] Windowing functionality added to scala api
commit a4c4f26e70088ed5cd5bf8a8f01585f09674cf04
Author: mbalassi <[email protected]>
Date: 2014-12-15T13:15:35Z
[scala] [streaming] Added SplitDataStream functionality
Conflicts:
flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala
commit 1922dbdb78019136310f0214395a9b0de27bbc49
Author: Gyula Fora <[email protected]>
Date: 2014-12-18T21:46:00Z
[scala] [streaming] Added support for iterative streams for scala api
commit 652327be3a1196fd98e18a777a24e36e6574da28
Author: Gyula Fora <[email protected]>
Date: 2014-12-19T20:05:01Z
[streaming] Temporal join and cross rework for consistence and extended
features
commit 739fdf0b76560f96b1b2dd9d9dbfba6eff1170bc
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T17:12:19Z
[scala] [streaming] Temporal join operator added
commit 40a3b6bc35ceff115a549f6094602d64b6eb69e9
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T18:34:55Z
[scala] [streaming] Temporal cross operator added
commit f7291ea1c9fa4a0484ab6bc13e4a594ff6d7c2d2
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T22:46:35Z
[scala] [streaming] Modified aggregations to work on scala tuples
commit 1f7b6eaaa979e91799a047f29881f82666c12b19
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T00:05:40Z
[scala] [streaming] Fixed scala formatting
commit 141348426eeae2ea0e4404a0d8cff8182c601886
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T02:54:30Z
[scala] [streaming] Added groupBy support for case class fields
commit c6b90eed5e2a3e1ce51bdca436a2bebc06a87ca7
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T12:10:34Z
[scala] [streaming] WindowJoin scala example added
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
