397 messages

org.apache.flink.commits [All Lists]

2015 March [All Months]

Page 1 (Messages 1 to 25): 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

svn commit: r1664032 - /flink/community.md - mx...@apache.org
[2/3] flink git commit: [tests] Add test for restart recovery - sew...@apache.org
[2/3] flink git commit: [FLINK-1631] [client] Overhaul of the client. - sew...@apache.org
[07/14] flink git commit: [FLINK-1638] [streaming] Added connector for low level Kafka Consumer API - sew...@apache.org
[09/14] flink git commit: [FLINK-1638] [streaming] Added persistent Kafka source - sew...@apache.org
[01/14] flink git commit: [FLINK-1638] [streaming] Operator state checkpointing and injection prototype - sew...@apache.org
[11/14] flink git commit: [FLINK-1638] [streaming] At-Least once monitoring semantics added and bug fixes - sew...@apache.org
[2/5] flink git commit: [FLINK-1619] [FLINK-1620] Basic sliding prereducers added for Time and Count - gyf...@apache.org
[1/8] flink git commit: [optimizer] Remove obsolete and unused fields from OptimizerNode - sew...@apache.org
[4/4] flink git commit: [docs] Remove -j and -a parameters which seemed no longer valid in the doc example for submit job to Flink run in YARN. - sew...@apache.org
[1/4] flink git commit: [FLINK-1714] Fix logger of the class SecurityUtils - sew...@apache.org
[01/13] flink git commit: [runtime] [tests] Run ProcessFailureBatchRecoveryITCase in BATCH and PIPELINED execution mode - uc...@apache.org
[12/13] flink git commit: [FLINK-1350] [runtime] Add blocking result partition variant - uc...@apache.org
flink git commit: [ml] [tests] Force pipelined execution of ALSITCase - uc...@apache.org
[2/2] flink git commit: [FLINK-1709] Add initial SlotCountExceedingParallelismTest - uc...@apache.org
[2/2] flink git commit: [FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11 - sew...@apache.org
[40/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to "flink-optimizer" (previously flink-compiler) - sew...@apache.org
[53/53] [abbrv] flink git commit: [FLINK-441] [optimizer] Rename Pact* and Nephele* classes - sew...@apache.org
[1/4] flink git commit: [streaming] Improve comments for source functions. Minor cleanups. - sew...@apache.org
[7/9] flink git commit: [FLINK-1679] use a consistent name for parallelism - mx...@apache.org
flink git commit: Update Javadoc from Nephele task manager to Task Manager; add missing Javadoc params in RegularPactTask#getOutputCollector. - hsap...@apache.org
[2/2] flink git commit: [FLINK-1686] [streaming] Use different slot identifier per iteration - gyf...@apache.org
[02/12] flink git commit: [FLINK-1623] Rename Expression API to Table API - aljo...@apache.org
[4/4] flink git commit: [FLINK-1774] Remove the redundant code in try{} block. - sew...@apache.org
flink git commit: [FLINK-1766]Fix the bug of equals function of FSKey - hsap...@apache.org

Page 1 (Messages 1 to 25): 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16