211 messages

org.apache.flink.commits [All Lists]

2014 December [All Months]

Page 8 (Messages 176 to 200): 1 2 3 4 5 6 7 8 9

[32/34] incubator-flink git commit: [streaming] Changed GroupedWindowInvokable to always delete groups in case they have an empty element buffer - mbal...@apache.org
[25/34] incubator-flink git commit: [streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies - mbal...@apache.org
[09/34] incubator-flink git commit: [streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases. - mbal...@apache.org
[10/34] incubator-flink git commit: [streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions. - mbal...@apache.org
[12/34] incubator-flink git commit: [streaming] Adding unit tests for the grouped windowing invokable. - mbal...@apache.org
[14/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes - mbal...@apache.org
[4/4] incubator-flink git commit: [java8] Fix pom.xml to properly work with Eclipse m2e - sew...@apache.org
[3/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - fhue...@apache.org
[2/4] incubator-flink git commit: [scala] Change ScalaAggregateOperator to use TypeSerializer - sew...@apache.org
incubator-flink git commit: [FLINK-1327] [core] Fix wrapping of MemorySegments in ByteBuffers - sew...@apache.org
[4/5] incubator-flink git commit: [FLINK-1325] [Java API] Minor cleanups on the ClosureCleaner - sew...@apache.org
[1/2] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples - mbal...@apache.org
[2/7] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples - mbal...@apache.org
[5/7] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer - mbal...@apache.org
[37/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
[60/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. - troh...@apache.org
incubator-flink git commit: 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. - troh...@apache.org
incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method - sew...@apache.org
[05/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
[31/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
[35/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
[38/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
[78/82] [abbrv] incubator-flink git commit: 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. - troh...@apache.org
[79/82] [abbrv] incubator-flink git commit: Exclude netty dependency from hadoop-mapreduce-client-core to resolve dependency conflict - troh...@apache.org
incubator-flink git commit: [streaming] Streaming local execution fix to create proper jobclient for minicluster - mbal...@apache.org

Page 8 (Messages 176 to 200): 1 2 3 4 5 6 7 8 9