211 messages

org.apache.flink.commits [All Lists]

2014 December [All Months]

Page 4 (Messages 76 to 100): 1 2 3 4 5 6 7 8 9

[02/34] incubator-flink git commit: [streaming] Created tumbling eviction policy. This policy evicts always all tuples after a trigger occurred. It can be used to prevent doubled computation between trigger and eviction policies whenever tumbling windows - mbal...@apache.org
[11/34] incubator-flink git commit: [streaming] Created trigger and eviction policies which calculate a delta between two data points using a given delta function. The policies evict/trigger in case the delta is higher than a specified threshold. (incl. - mbal...@apache.org
[3/5] incubator-flink git commit: [streaming] Java 8 WordCount example added for streaming - mbal...@apache.org
[4/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas - mbal...@apache.org
[5/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - fhue...@apache.org
incubator-flink git commit: [FLINK-1310] Change ClosureCleaner Logging to DEBUG - uc...@apache.org
[4/4] incubator-flink git commit: [FLINK-1305] [FLINK-1304] Test for HadoopInputWrapper and NullWritable support - sew...@apache.org
incubator-flink git commit: [Distributed runtime] Fail task if execution state update is unsuccessful - uc...@apache.org
[2/5] incubator-flink git commit: [FLINK-1325] [streaming] Added clousure cleaning to streaming - mbal...@apache.org
[3/7] incubator-flink git commit: [streaming] DataStream print functionality update - mbal...@apache.org
[49/82] [abbrv] incubator-flink git commit: Removed dead instance cleanup from InstanceManager so that Akka's watch mechanism is the current mean to detect dead instances. - troh...@apache.org
[65/82] [abbrv] incubator-flink git commit: Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout. - troh...@apache.org
[82/82] [abbrv] incubator-flink git commit: Remove experimental KryoSerialization for Akka - troh...@apache.org
[81/82] [abbrv] incubator-flink git commit: Fix race condition in ExecutionGraph which made the job finish before all vertices have called the finalizeOnMaster method. - troh...@apache.org
[12/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[21/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[22/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[43/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[44/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[46/82] [abbrv] incubator-flink git commit: Updated DEPENDENCIES, NOTICE and LICENSE files. - troh...@apache.org
[5/6] incubator-flink git commit: [streaming] Added immutability for window and filter operators - mbal...@apache.org
[6/6] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. - mbal...@apache.org
[4/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - mbal...@apache.org
[5/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - mbal...@apache.org
incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation - mbal...@apache.org

Page 4 (Messages 76 to 100): 1 2 3 4 5 6 7 8 9