You are viewing a plain text version of this content. The canonical link for it is here.
- [01/27] incubator-flink git commit: [streaming] Time trigger preNotify fix - posted by mb...@apache.org on 2015/01/04 21:50:51 UTC, 0 replies.
- [02/27] incubator-flink git commit: [scala] [streaming] Fixed scala formatting - posted by mb...@apache.org on 2015/01/04 21:50:52 UTC, 0 replies.
- [03/27] incubator-flink git commit: [scala] [streaming] Temporal cross operator added - posted by mb...@apache.org on 2015/01/04 21:50:53 UTC, 0 replies.
- [04/27] incubator-flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples - posted by mb...@apache.org on 2015/01/04 21:50:54 UTC, 0 replies.
- [05/27] incubator-flink git commit: [scala] [streaming] Base functionality added for streaming scala api - posted by mb...@apache.org on 2015/01/04 21:50:55 UTC, 0 replies.
- [06/27] incubator-flink git commit: [scala] [streaming] Temporal join operator added - posted by mb...@apache.org on 2015/01/04 21:50:56 UTC, 0 replies.
- [07/27] incubator-flink git commit: [scala] [streaming] Windowing functionality added to scala api - posted by mb...@apache.org on 2015/01/04 21:50:57 UTC, 0 replies.
- [08/27] incubator-flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators - posted by mb...@apache.org on 2015/01/04 21:50:58 UTC, 0 replies.
- [09/27] incubator-flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs - posted by mb...@apache.org on 2015/01/04 21:50:59 UTC, 0 replies.
- [10/27] incubator-flink git commit: [scala] [streaming] Added SplitDataStream functionality - posted by mb...@apache.org on 2015/01/04 21:51:00 UTC, 0 replies.
- [11/27] incubator-flink git commit: [streaming] Temporal join and cross rework for consistence and extended features - posted by mb...@apache.org on 2015/01/04 21:51:01 UTC, 0 replies.
- [12/27] incubator-flink git commit: [scala] [streaming] Added support for iterative streams for scala api - posted by mb...@apache.org on 2015/01/04 21:51:02 UTC, 0 replies.
- [13/27] incubator-flink git commit: [streaming] Streaming API grouping rework to use batch api Keys - posted by mb...@apache.org on 2015/01/04 21:51:03 UTC, 0 replies.
- [14/27] incubator-flink git commit: [scala] [streaming] Added groupBy support for case class fields - posted by mb...@apache.org on 2015/01/04 21:51:04 UTC, 0 replies.
- [15/27] incubator-flink git commit: [scala] [streaming] WindowJoin scala example added - posted by mb...@apache.org on 2015/01/04 21:51:05 UTC, 0 replies.
- [16/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support - posted by mb...@apache.org on 2015/01/04 21:51:06 UTC, 0 replies.
- [17/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support - posted by mb...@apache.org on 2015/01/04 21:51:07 UTC, 0 replies.
- [18/27] incubator-flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams - posted by mb...@apache.org on 2015/01/04 21:51:08 UTC, 0 replies.
- [19/27] incubator-flink git commit: [scala] [streaming] added group windowing example with different policy types - posted by mb...@apache.org on 2015/01/04 21:51:09 UTC, 0 replies.
- [20/27] incubator-flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api - posted by mb...@apache.org on 2015/01/04 21:51:10 UTC, 0 replies.
- [21/27] incubator-flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams - posted by mb...@apache.org on 2015/01/04 21:51:11 UTC, 0 replies.
- [22/27] incubator-flink git commit: [streaming] Source parallelism + connector rework - posted by mb...@apache.org on 2015/01/04 21:51:12 UTC, 0 replies.
- [23/27] incubator-flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface - posted by mb...@apache.org on 2015/01/04 21:51:13 UTC, 0 replies.
- [24/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/04 21:51:14 UTC, 0 replies.
- [25/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/04 21:51:15 UTC, 0 replies.
- [26/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/04 21:51:16 UTC, 0 replies.
- [27/27] incubator-flink git commit: [docs] Trivial typo in example code: o -> out. - posted by mb...@apache.org on 2015/01/04 21:51:17 UTC, 0 replies.
- [1/8] incubator-flink git commit: [docs] Remove files from obolete and unused figures - posted by se...@apache.org on 2015/01/05 16:20:38 UTC, 0 replies.
- [2/8] incubator-flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs - posted by se...@apache.org on 2015/01/05 16:20:39 UTC, 0 replies.
- [3/8] incubator-flink git commit: [FLINK-1346] [docs] Add stubs for Akka documentation - posted by se...@apache.org on 2015/01/05 16:20:40 UTC, 0 replies.
- [4/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. - posted by se...@apache.org on 2015/01/05 16:20:41 UTC, 0 replies.
- [5/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. - posted by se...@apache.org on 2015/01/05 16:20:42 UTC, 0 replies.
- [6/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. - posted by se...@apache.org on 2015/01/05 16:20:43 UTC, 0 replies.
- [7/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. - posted by se...@apache.org on 2015/01/05 16:20:44 UTC, 0 replies.
- [8/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. - posted by se...@apache.org on 2015/01/05 16:20:45 UTC, 0 replies.
- incubator-flink git commit: Remove full package name for FlatMapOperatorBase - posted by hs...@apache.org on 2015/01/05 19:54:10 UTC, 0 replies.
- [1/4] incubator-flink git commit: [FLINK-1349] [runtime] Various cleanups to make scala runtime code interact smoother with java - posted by se...@apache.org on 2015/01/06 11:45:28 UTC, 0 replies.
- [2/4] incubator-flink git commit: [FLINK-1349] [runtime] Various fixes concerning Akka - Remove obsolete code from old IPC net utils - Smaller Writable/IOReadableWritable serialzation buffer start size (most messages are rather small) - For message lo - posted by se...@apache.org on 2015/01/06 11:45:29 UTC, 0 replies.
- [3/4] incubator-flink git commit: [FLINK-1349] [runtime] Various fixes concerning Akka - Remove obsolete code from old IPC net utils - Smaller Writable/IOReadableWritable serialzation buffer start size (most messages are rather small) - For message lo - posted by se...@apache.org on 2015/01/06 11:45:30 UTC, 0 replies.
- [4/4] incubator-flink git commit: [FLINK-1335] [docs] Add guide how to set up Eclipse, and bring README.md up to speed. - posted by se...@apache.org on 2015/01/06 11:45:31 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1335] [docs] Minor fix to README file - posted by se...@apache.org on 2015/01/06 13:01:47 UTC, 0 replies.
- [1/3] incubator-flink git commit: [FLINK-1357] [compiler] Add union between static and dynamic path - posted by se...@apache.org on 2015/01/06 14:20:32 UTC, 0 replies.
- [2/3] incubator-flink git commit: [FLINK-1027] [cli] Added support for '--' and '-' prefixed tokens in CLI program arguments. - posted by se...@apache.org on 2015/01/06 14:20:33 UTC, 0 replies.
- [3/3] incubator-flink git commit: [FLINK-1236] [hadoop compatibility] Add local split assignment support for HadoopInputFormats - posted by se...@apache.org on 2015/01/06 14:20:34 UTC, 0 replies.
- [1/5] incubator-flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples - posted by mb...@apache.org on 2015/01/06 15:43:20 UTC, 0 replies.
- [2/5] incubator-flink git commit: [streaming] Updated streaming guide for recent connector and data source changes - posted by mb...@apache.org on 2015/01/06 15:43:21 UTC, 0 replies.
- [3/5] incubator-flink git commit: [streaming] Temporal operator windowing syntax update - posted by mb...@apache.org on 2015/01/06 15:43:22 UTC, 0 replies.
- [4/5] incubator-flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions - posted by mb...@apache.org on 2015/01/06 15:43:23 UTC, 0 replies.
- [5/5] incubator-flink git commit: [streaming] Deleted obsolete parts of the connected stream api - posted by mb...@apache.org on 2015/01/06 15:43:24 UTC, 0 replies.
- [1/3] incubator-flink git commit: [FLINK-1169] [apis] Add documentation for join hints. - posted by se...@apache.org on 2015/01/06 16:50:11 UTC, 0 replies.
- [2/3] incubator-flink git commit: [FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements. - posted by se...@apache.org on 2015/01/06 16:50:12 UTC, 0 replies.
- [3/3] incubator-flink git commit: [FLINK-1300] [core] Remove unused and redundant files DataInputViewStream and DataOutputViewStream. - posted by se...@apache.org on 2015/01/06 16:50:13 UTC, 0 replies.
- svn commit: r1649876 - /flink/ - posted by co...@apache.org on 2015/01/06 18:13:12 UTC, 0 replies.
- svn commit: r1649876 - /incubator/flink/ - posted by co...@apache.org on 2015/01/06 18:13:17 UTC, 0 replies.
- svn commit: r1649922 - /flink/doap_flink.rdf - posted by rm...@apache.org on 2015/01/06 21:08:09 UTC, 0 replies.
- svn commit: r1649923 - in /flink/site: doap_flink.rdf index.html - posted by rm...@apache.org on 2015/01/06 21:12:15 UTC, 0 replies.
- svn commit: r1650029 - in /flink: _posts/2015-01-06-december-in-flink.md site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html site/news/2015/ site/news/2015/01/ site/news/2015/01/06/ site/news/2015/01/06/december-in-flink.html - posted by kt...@apache.org on 2015/01/07 11:40:31 UTC, 0 replies.
- flink git commit: [FLINK-1363] [runtime tests] Fix race condition in ExecutionVertexCancelTest.testSendCancelAndReceiveFail - posted by tr...@apache.org on 2015/01/07 14:41:50 UTC, 0 replies.
- [01/36] flink git commit: [streaming] Time trigger preNotify fix - posted by mb...@apache.org on 2015/01/07 15:12:40 UTC, 0 replies.
- [02/36] flink git commit: [scala] [streaming] Base functionality added for streaming scala api - posted by mb...@apache.org on 2015/01/07 15:12:41 UTC, 0 replies.
- [03/36] flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators - posted by mb...@apache.org on 2015/01/07 15:12:42 UTC, 0 replies.
- [04/36] flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs - posted by mb...@apache.org on 2015/01/07 15:12:43 UTC, 0 replies.
- [05/36] flink git commit: [scala] [streaming] Windowing functionality added to scala api - posted by mb...@apache.org on 2015/01/07 15:12:44 UTC, 0 replies.
- [06/36] flink git commit: [scala] [streaming] Added SplitDataStream functionality - posted by mb...@apache.org on 2015/01/07 15:12:45 UTC, 0 replies.
- [07/36] flink git commit: [scala] [streaming] Added support for iterative streams for scala api - posted by mb...@apache.org on 2015/01/07 15:12:46 UTC, 0 replies.
- [08/36] flink git commit: [streaming] Temporal join and cross rework for consistence and extended features - posted by mb...@apache.org on 2015/01/07 15:12:47 UTC, 0 replies.
- [09/36] flink git commit: [scala] [streaming] Temporal join operator added - posted by mb...@apache.org on 2015/01/07 15:12:48 UTC, 0 replies.
- [10/36] flink git commit: [scala] [streaming] Temporal cross operator added - posted by mb...@apache.org on 2015/01/07 15:12:49 UTC, 0 replies.
- [11/36] flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples - posted by mb...@apache.org on 2015/01/07 15:12:50 UTC, 0 replies.
- [12/36] flink git commit: [scala] [streaming] Fixed scala formatting - posted by mb...@apache.org on 2015/01/07 15:12:51 UTC, 0 replies.
- [13/36] flink git commit: [scala] [streaming] Added groupBy support for case class fields - posted by mb...@apache.org on 2015/01/07 15:12:52 UTC, 0 replies.
- [14/36] flink git commit: [scala] [streaming] WindowJoin scala example added - posted by mb...@apache.org on 2015/01/07 15:12:53 UTC, 0 replies.
- [15/36] flink git commit: [streaming] Streaming API grouping rework to use batch api Keys - posted by mb...@apache.org on 2015/01/07 15:12:54 UTC, 0 replies.
- [16/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support - posted by mb...@apache.org on 2015/01/07 15:12:55 UTC, 0 replies.
- [17/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support - posted by mb...@apache.org on 2015/01/07 15:12:56 UTC, 0 replies.
- [18/36] flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams - posted by mb...@apache.org on 2015/01/07 15:12:57 UTC, 0 replies.
- [19/36] flink git commit: [scala] [streaming] added group windowing example with different policy types - posted by mb...@apache.org on 2015/01/07 15:12:58 UTC, 0 replies.
- [20/36] flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api - posted by mb...@apache.org on 2015/01/07 15:12:59 UTC, 0 replies.
- [21/36] flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams - posted by mb...@apache.org on 2015/01/07 15:13:00 UTC, 0 replies.
- [22/36] flink git commit: [streaming] Source parallelism + connector rework - posted by mb...@apache.org on 2015/01/07 15:13:01 UTC, 0 replies.
- [23/36] flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface - posted by mb...@apache.org on 2015/01/07 15:13:02 UTC, 0 replies.
- [24/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/07 15:13:03 UTC, 0 replies.
- [25/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/07 15:13:04 UTC, 0 replies.
- [26/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples - posted by mb...@apache.org on 2015/01/07 15:13:05 UTC, 0 replies.
- [27/36] flink git commit: [docs] Trivial typo in example code: o -> out. - posted by mb...@apache.org on 2015/01/07 15:13:06 UTC, 0 replies.
- [28/36] flink git commit: [docs] Remove files from obolete and unused figures - posted by mb...@apache.org on 2015/01/07 15:13:07 UTC, 0 replies.
- [29/36] flink git commit: [streaming] Temporal operator windowing syntax update - posted by mb...@apache.org on 2015/01/07 15:13:08 UTC, 0 replies.
- [30/36] flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs - posted by mb...@apache.org on 2015/01/07 15:13:09 UTC, 0 replies.
- [31/36] flink git commit: [streaming] Deleted obsolete parts of the connected stream api - posted by mb...@apache.org on 2015/01/07 15:13:10 UTC, 0 replies.
- [32/36] flink git commit: [streaming] Updated streaming guide for recent connector and data source changes - posted by mb...@apache.org on 2015/01/07 15:13:11 UTC, 0 replies.
- [33/36] flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions - posted by mb...@apache.org on 2015/01/07 15:13:12 UTC, 0 replies.
- [34/36] flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples - posted by mb...@apache.org on 2015/01/07 15:13:13 UTC, 0 replies.
- [35/36] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes - posted by mb...@apache.org on 2015/01/07 15:13:14 UTC, 0 replies.
- [36/36] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning - posted by mb...@apache.org on 2015/01/07 15:13:15 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1365] Fix ValueTypeInfo - posted by al...@apache.org on 2015/01/07 16:05:02 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1366] Enable FastPath in TextValueInputFormat again - posted by al...@apache.org on 2015/01/07 16:05:03 UTC, 0 replies.
- flink git commit: Commit for release 0.8.0 - posted by mb...@apache.org on 2015/01/07 17:40:53 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-1361] change jobManager log file name back to old value - posted by se...@apache.org on 2015/01/07 18:34:52 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1354] Made test graph for TransitiveClosureITCase smaller - posted by se...@apache.org on 2015/01/07 18:34:53 UTC, 0 replies.
- [01/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting - posted by se...@apache.org on 2015/01/08 11:58:56 UTC, 0 replies.
- [02/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting - posted by se...@apache.org on 2015/01/08 11:58:57 UTC, 0 replies.
- [03/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:58:58 UTC, 0 replies.
- [04/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:58:59 UTC, 0 replies.
- [05/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:00 UTC, 0 replies.
- [06/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:01 UTC, 0 replies.
- [07/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:02 UTC, 0 replies.
- [08/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:03 UTC, 0 replies.
- [09/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:04 UTC, 0 replies.
- [10/13] flink git commit: [FLINK-1285] Make execution mode configurable - posted by se...@apache.org on 2015/01/08 11:59:05 UTC, 0 replies.
- [11/13] flink git commit: [FLINK-1137] Enhance MutableObjectIterator with non-reuse next() - posted by se...@apache.org on 2015/01/08 11:59:06 UTC, 0 replies.
- [12/13] flink git commit: [FLINK-1285] Various cleanup of object reusing and non-reusing code. - posted by se...@apache.org on 2015/01/08 11:59:07 UTC, 0 replies.
- [13/13] flink git commit: [runtime] Release additional broadcast variable references early - posted by se...@apache.org on 2015/01/08 11:59:08 UTC, 0 replies.
- flink git commit: [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions - posted by se...@apache.org on 2015/01/08 12:49:58 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-1367] [scala] [streaming] Field aggregations added to streaming scala api - posted by mb...@apache.org on 2015/01/08 15:54:21 UTC, 0 replies.
- [2/3] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning - posted by mb...@apache.org on 2015/01/08 15:54:22 UTC, 0 replies.
- [3/3] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes - posted by mb...@apache.org on 2015/01/08 15:54:23 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators - posted by se...@apache.org on 2015/01/08 16:32:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators - posted by se...@apache.org on 2015/01/08 16:32:50 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems - posted by rm...@apache.org on 2015/01/08 16:42:41 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-1266] Update mongodb link and address pull request comments - posted by rm...@apache.org on 2015/01/08 16:42:42 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. Th - posted by rm...@apache.org on 2015/01/08 16:42:43 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. Th - posted by rm...@apache.org on 2015/01/08 16:42:44 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-1266] More dependency exclusions & fixed image in web client - posted by rm...@apache.org on 2015/01/08 16:42:45 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-333] [apis] Forward crossWithSmall and crossWithLarge hints to optimizer. - posted by se...@apache.org on 2015/01/08 19:11:31 UTC, 0 replies.
- [2/2] flink git commit: [docs] Update README and internals (scheduling) for graduation and fix broken links - posted by se...@apache.org on 2015/01/08 19:11:32 UTC, 0 replies.
- flink git commit: Fix typo in README.md - posted by uc...@apache.org on 2015/01/09 15:00:18 UTC, 0 replies.
- svn commit: r1650553 - in /flink: ./ _includes/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/ site/news/2013/03/27/ site/news/2013/10/21/ site/news/... - posted by kt...@apache.org on 2015/01/09 16:03:13 UTC, 0 replies.
- flink git commit: [FLINK-1197] [docs] Add information about types and type extraction - posted by se...@apache.org on 2015/01/09 17:33:04 UTC, 0 replies.
- svn commit: r1650626 - in /flink: ./ _includes/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/ site/news/2013/03/27/ site/news/2013/10/21/ site/news/... - posted by kt...@apache.org on 2015/01/09 19:39:20 UTC, 0 replies.
- [01/15] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. - posted by se...@apache.org on 2015/01/10 19:19:38 UTC, 0 replies.
- [02/15] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. - posted by se...@apache.org on 2015/01/10 19:19:39 UTC, 0 replies.
- [03/15] flink git commit: [FLINK-1266] Update mongodb link and address pull request comments - posted by se...@apache.org on 2015/01/10 19:19:40 UTC, 0 replies.
- [04/15] flink git commit: [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems - posted by se...@apache.org on 2015/01/10 19:19:41 UTC, 0 replies.
- [05/15] flink git commit: [FLINK-1266] More dependency exclusions - posted by se...@apache.org on 2015/01/10 19:19:42 UTC, 0 replies.
- [06/15] flink git commit: [FLINK-1266] Backport fix to 0.8 - posted by se...@apache.org on 2015/01/10 19:19:43 UTC, 0 replies.
- [07/15] flink git commit: [FLINK-1375] [assembly] Remove incubator DISCLAIMER file from binary distribution - posted by se...@apache.org on 2015/01/10 19:19:44 UTC, 0 replies.
- [08/15] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/10 19:19:45 UTC, 0 replies.
- [09/15] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/10 19:19:46 UTC, 0 replies.
- [10/15] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/10 19:19:47 UTC, 0 replies.
- [11/15] flink git commit: Minor dependencies cleanup: - Move sling JSON dependency to streaming connectors (prev streaming core) - Exclude YARN API from transitive mapreduce-core dependencies we use the dependency only for .mapred and .mapreduce - posted by se...@apache.org on 2015/01/10 19:19:48 UTC, 0 replies.
- [12/15] flink git commit: [tachyon] Minor fix in codestyle and warnings - posted by se...@apache.org on 2015/01/10 19:19:49 UTC, 0 replies.
- [13/15] flink git commit: [docs] Add FAQ entry about scala implicits error when missing imports - posted by se...@apache.org on 2015/01/10 19:19:50 UTC, 0 replies.
- [14/15] flink git commit: [FLINK-1384] [webfrontend] Remove unused JS libraries - posted by se...@apache.org on 2015/01/10 19:19:51 UTC, 0 replies.
- [15/15] flink git commit: [LICENSE] Update LICENSE and NOTICE files - Add missing entries for dependencies - Remove entries for removed dependencies - Change DEPENDENCIES file to point to src and bin LICENSE and NOTICE file - Add comments in some fil - posted by se...@apache.org on 2015/01/10 19:19:52 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1386] [quickstart] Fix pom in java quickstart archetype - posted by se...@apache.org on 2015/01/11 20:36:26 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1358] [streaming] Streaming added to the quickstarts - posted by se...@apache.org on 2015/01/11 20:36:27 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1225] Fix for quickstart packaging - posted by se...@apache.org on 2015/01/11 20:36:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1358] [streaming] Streaming added to the quickstarts - posted by se...@apache.org on 2015/01/11 20:39:19 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1386] [quickstart] Fix pom in java quickstart archetype - posted by se...@apache.org on 2015/01/11 20:39:20 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1378] [scala] Add support for Try[A] (Success/Failure) - posted by se...@apache.org on 2015/01/11 21:45:19 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1378] Add support for Throwables in KryoSerializer - posted by se...@apache.org on 2015/01/11 21:45:20 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-1378] [scala] Fix type extraction for nested type parameters - posted by se...@apache.org on 2015/01/11 21:45:21 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1378] [scala] Fix type extraction for nested type parameters - posted by se...@apache.org on 2015/01/11 22:51:39 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1378] [scala] Add support for Try[A] (Success/Failure) - posted by se...@apache.org on 2015/01/11 22:51:41 UTC, 0 replies.
- svn commit: r1650985 - in /flink: ./ _layouts/ img/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/img/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/ site/news/2013/03/27/ site/news/2013/10/... - posted by rm...@apache.org on 2015/01/12 00:04:56 UTC, 0 replies.
- [01/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:09 UTC, 0 replies.
- [02/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:10 UTC, 0 replies.
- [03/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:11 UTC, 0 replies.
- [04/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:12 UTC, 0 replies.
- [05/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:13 UTC, 0 replies.
- [06/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:14 UTC, 0 replies.
- [07/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:15 UTC, 0 replies.
- [08/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:16 UTC, 0 replies.
- [09/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:17 UTC, 0 replies.
- [10/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:18 UTC, 0 replies.
- [11/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:19 UTC, 0 replies.
- [12/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:20 UTC, 0 replies.
- [13/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:21 UTC, 0 replies.
- [14/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:22 UTC, 0 replies.
- [15/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:23 UTC, 0 replies.
- [16/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:24 UTC, 0 replies.
- [17/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:25 UTC, 0 replies.
- [18/18] flink git commit: [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results - posted by uc...@apache.org on 2015/01/12 09:16:26 UTC, 0 replies.
- flink git commit: [FLINK-1380] [streaming] Updated SplitDataStream to extend DataStream to get rid of selectAll method for splits - posted by mb...@apache.org on 2015/01/12 11:20:11 UTC, 0 replies.
- [1/5] flink git commit: [docs] Prepare documentation for 0.8 release - posted by mb...@apache.org on 2015/01/12 11:25:05 UTC, 0 replies.
- [2/5] flink git commit: [docs] Update README and internals (scheduling) for graduation and fix broken links - posted by mb...@apache.org on 2015/01/12 11:25:06 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-1385] Print warning if not resources are _currently_ available in the YARN cluster. Instead of rejecting the session - posted by mb...@apache.org on 2015/01/12 11:25:07 UTC, 0 replies.
- [4/5] flink git commit: Fix typo in README.md - posted by mb...@apache.org on 2015/01/12 11:25:08 UTC, 0 replies.
- [5/5] flink git commit: [dist] Updated mailing list info in binary distribution - posted by mb...@apache.org on 2015/01/12 11:25:09 UTC, 0 replies.
- flink git commit: Undo erroneous commit 86f87537 - posted by rm...@apache.org on 2015/01/12 13:28:10 UTC, 0 replies.
- flink git commit: [scala] Disable Warning Message in TypeAnalyzer - posted by al...@apache.org on 2015/01/13 14:45:05 UTC, 0 replies.
- flink git commit: [FLINK-1397] Fix logfile access from JobManager web interface - posted by rm...@apache.org on 2015/01/14 10:37:58 UTC, 1 replies.
- flink git commit: Fix for quickstart versions - posted by mb...@apache.org on 2015/01/14 11:47:39 UTC, 0 replies.
- svn commit: r1651676 - in /flink: index.html site/index.html - posted by kt...@apache.org on 2015/01/14 15:19:26 UTC, 0 replies.
- svn commit: r1651731 - in /flink: material.md site/material.html - posted by kt...@apache.org on 2015/01/14 17:57:58 UTC, 0 replies.
- flink git commit: Remove dup code fromRemoteExecutor#executePlan method - posted by hs...@apache.org on 2015/01/15 01:57:59 UTC, 0 replies.
- [1/3] flink git commit: [build tools] Release script update - posted by mb...@apache.org on 2015/01/15 11:54:14 UTC, 0 replies.
- [2/3] flink git commit: Commit for year 2015 - posted by mb...@apache.org on 2015/01/15 11:54:15 UTC, 0 replies.
- [3/3] flink git commit: Commit for release 0.8.0 - posted by mb...@apache.org on 2015/01/15 11:54:16 UTC, 0 replies.
- flink git commit: [FLINK-1405] [windows] Fix Windows scripts (flink.bat and start-local.bat) - Fix for paths with blank characters - Fix for single entry wildcard classpaths (http://bugs.java.com, bugID: 7146578) - posted by fh...@apache.org on 2015/01/15 11:54:18 UTC, 0 replies.
- [1/2] flink git commit: [build tools] Release script update - posted by mb...@apache.org on 2015/01/15 11:54:51 UTC, 0 replies.
- [2/2] flink git commit: Commit for year 2015 - posted by mb...@apache.org on 2015/01/15 11:54:52 UTC, 0 replies.
- flink git commit: [hotfix] Also use java closure cleaner on grouped operations - posted by al...@apache.org on 2015/01/15 11:58:33 UTC, 0 replies.
- flink git commit: [FLINK-1183] Generate gentle notification message when Flink is started with Java 6 - posted by uc...@apache.org on 2015/01/15 17:10:14 UTC, 1 replies.
- flink git commit: [FLINK-1183] Generate gentle notification message when Flink is started with Java 6 (backport) - posted by uc...@apache.org on 2015/01/15 17:23:04 UTC, 0 replies.
- flink git commit: [FLINK-1271] [hadoop] Remove Writable limitation from Hadoop format and function wrappers - posted by fh...@apache.org on 2015/01/15 17:49:03 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1112] Additional checks for KeySelector group sorting and minor fixes - posted by fh...@apache.org on 2015/01/15 18:15:01 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1112] Add KeySelector group sorting on KeySelector grouping - posted by fh...@apache.org on 2015/01/15 18:15:02 UTC, 0 replies.
- Git Push Summary - posted by uc...@apache.org on 2015/01/16 10:43:41 UTC, 3 replies.
- flink git commit: [runtime tests] Fixes TaskManagerTest.testRunJobWithForwardChannel which caused spurious errors. Doubles the timeout for tests. - posted by tr...@apache.org on 2015/01/16 14:27:42 UTC, 0 replies.
- svn commit: r1652422 [1/2] - in /flink: ./ _includes/ _layouts/ blog/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/ site/news/2013/03/27/ site/news/... - posted by rm...@apache.org on 2015/01/16 15:40:05 UTC, 0 replies.
- svn commit: r1652422 [2/2] - in /flink: ./ _includes/ _layouts/ blog/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/ site/news/2013/03/27/ site/news/... - posted by rm...@apache.org on 2015/01/16 15:40:05 UTC, 0 replies.
- svn commit: r1652423 - /flink/site/blog/feed.xml - posted by rm...@apache.org on 2015/01/16 15:40:58 UTC, 0 replies.
- [01/17] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/18 20:03:07 UTC, 0 replies.
- [02/17] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/18 20:03:08 UTC, 0 replies.
- [03/17] flink git commit: [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 - posted by se...@apache.org on 2015/01/18 20:03:09 UTC, 0 replies.
- [04/17] flink git commit: [FLINK-1375] [assembly] Remove incubator DISCLAIMER file from binary distribution - posted by se...@apache.org on 2015/01/18 20:03:10 UTC, 0 replies.
- [05/17] flink git commit: [LICENSE] Update LICENSE and NOTICE files - Add missing entries for dependencies - Remove entries for removed dependencies - Change DEPENDENCIES file to point to src and bin LICENSE and NOTICE file - Add comments in some fil - posted by se...@apache.org on 2015/01/18 20:03:11 UTC, 0 replies.
- [06/17] flink git commit: [FLINK-1384] [webfrontend] Remove unused JS libraries - posted by se...@apache.org on 2015/01/18 20:03:12 UTC, 0 replies.
- [07/17] flink git commit: [docs] Add FAQ entry about scala implicits error when missing imports - posted by se...@apache.org on 2015/01/18 20:03:13 UTC, 0 replies.
- [08/17] flink git commit: [tachyon] Minor fix in codestyle and warnings - posted by se...@apache.org on 2015/01/18 20:03:14 UTC, 0 replies.
- [09/17] flink git commit: Minor dependencies cleanup: - Move sling JSON dependency to streaming connectors (prev streaming core) - Exclude YARN API from transitive mapreduce-core dependencies we use the dependency only for .mapred and .mapreduce - posted by se...@apache.org on 2015/01/18 20:03:15 UTC, 0 replies.
- [10/17] flink git commit: [dist] Updated mailing list info in binary distribution - posted by se...@apache.org on 2015/01/18 20:03:16 UTC, 0 replies.
- [11/17] flink git commit: Fix for quickstart versions - posted by se...@apache.org on 2015/01/18 20:03:17 UTC, 0 replies.
- [12/17] flink git commit: [docs] Prepare documentation for 0.8 release - posted by se...@apache.org on 2015/01/18 20:03:18 UTC, 0 replies.
- [13/17] flink git commit: [build tools] Release script update - posted by se...@apache.org on 2015/01/18 20:03:19 UTC, 0 replies.
- [14/17] flink git commit: [maven] Fix project name and inception year - posted by se...@apache.org on 2015/01/18 20:03:20 UTC, 0 replies.
- [15/17] flink git commit: [FLINK-1229][FLINK-1206] [web frontend] Synchronize webclient arguments with command line and add default parallelism. - posted by se...@apache.org on 2015/01/18 20:03:21 UTC, 0 replies.
- [16/17] flink git commit: [FLINK-1382][java] Adds the new basic types Void and Date to the TypeInfoParser - posted by se...@apache.org on 2015/01/18 20:03:22 UTC, 0 replies.
- [17/17] flink git commit: Commit for year 2015 - posted by se...@apache.org on 2015/01/18 20:03:23 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-1399] Add support for registering Serializers with Kryo - posted by se...@apache.org on 2015/01/19 00:29:16 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1399] Fix kryo registration of types and make sure that tags are assigned for registered types. - posted by se...@apache.org on 2015/01/19 00:29:17 UTC, 0 replies.
- [3/4] flink git commit: [tests] Make dates in test data agnostic to time zones - posted by se...@apache.org on 2015/01/19 00:29:18 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1416] Fix dependency versions in quickstart archetypes - posted by se...@apache.org on 2015/01/19 00:29:19 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1395] Add tests for custom serializers with JodaTime. - posted by se...@apache.org on 2015/01/19 06:46:08 UTC, 0 replies.
- [2/2] flink git commit: [tests] Minor cleanup of compiler warnings. - posted by se...@apache.org on 2015/01/19 06:46:09 UTC, 0 replies.
- [1/4] flink git commit: [Distributed runtime] Rename read method of BufferReader to indicate blocking behaviour - posted by uc...@apache.org on 2015/01/19 15:13:10 UTC, 0 replies.
- [2/4] flink git commit: [Distributed runtime] Allow recursive union of buffer readers - posted by uc...@apache.org on 2015/01/19 15:13:11 UTC, 0 replies.
- [3/4] flink git commit: [Distributed runtime] Refactor data availability listener of UnionBufferReader to increase readability - posted by uc...@apache.org on 2015/01/19 15:13:12 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1409] Let CoRecordReader subscribe to buffer reader notifications - posted by uc...@apache.org on 2015/01/19 15:13:13 UTC, 0 replies.
- flink git commit: Update incubator-flink name in the merge pull tools to flink. - posted by hs...@apache.org on 2015/01/19 19:13:40 UTC, 0 replies.
- flink git commit: FLINK-1420 Small cleanup on code after branch for 0.8 release - posted by hs...@apache.org on 2015/01/19 21:22:30 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-1372] Re-add logging of temp directories at task manager startup - posted by uc...@apache.org on 2015/01/20 20:31:06 UTC, 0 replies.
- [2/4] flink git commit: Adopts the logger level for the akka log level - posted by uc...@apache.org on 2015/01/20 20:31:07 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1372] [runtime] Fixes logging settings. The logging is now exclusively controlled by the logging properties provided to the system. Removes akka.loglevel config parameter. - posted by uc...@apache.org on 2015/01/20 20:31:08 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1372] Log memory usage at start up and fix log level mismatch for scheduled memory log message - posted by uc...@apache.org on 2015/01/20 20:31:09 UTC, 0 replies.
- flink git commit: Fix missing IOException import in JobManager - posted by uc...@apache.org on 2015/01/21 00:30:13 UTC, 0 replies.
- flink git commit: [Docs] Fix typo in programming guide - posted by uc...@apache.org on 2015/01/21 11:50:06 UTC, 1 replies.
- [1/9] flink git commit: [FLINK-1296] [runtime] Limit memory consumption on merged by spilling larger records into a single special merge stream - posted by uc...@apache.org on 2015/01/21 12:08:51 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-1326] [runtime] Make sure that serializers release their very large intermediate buffers early - posted by uc...@apache.org on 2015/01/21 12:08:52 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-1296] [runtime] Add sorter support for very large records - posted by uc...@apache.org on 2015/01/21 12:08:53 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-1296] [runtime] Add sorter support for very large records - posted by uc...@apache.org on 2015/01/21 12:08:54 UTC, 0 replies.
- [5/9] flink git commit: [runtime] Add spillable input deserializer - posted by uc...@apache.org on 2015/01/21 12:08:55 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-1296] [runtime] Add better paged disk I/O readers / writers - posted by uc...@apache.org on 2015/01/21 12:08:56 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-1296] [runtime] Fix bug that first record in buffer is not correctly recognized as large record - posted by uc...@apache.org on 2015/01/21 12:08:57 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-1296] [runtime] Fix bug when large record handling results in empty spill files - posted by uc...@apache.org on 2015/01/21 12:08:58 UTC, 0 replies.
- [9/9] flink git commit: Fix conflicts after rebase of PR #249 - posted by uc...@apache.org on 2015/01/21 12:08:59 UTC, 0 replies.
- flink git commit: [FLINK-1367] [scala] [streaming] Field aggregations added to streaming scala api - posted by mb...@apache.org on 2015/01/21 18:53:12 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-1403] [streaming] Distributed filesystem support for streaming filesinks - posted by mb...@apache.org on 2015/01/21 18:53:55 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-1345] [streaming] Basic operator chaining added - posted by mb...@apache.org on 2015/01/21 18:53:56 UTC, 0 replies.
- [3/8] flink git commit: [streaming] Streaming runtime collector rework for increased flexibility with directed outputs and operator chains - posted by mb...@apache.org on 2015/01/21 18:53:57 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-1345] [streaming] Advanced task chaining added - posted by mb...@apache.org on 2015/01/21 18:53:58 UTC, 0 replies.
- [5/8] flink git commit: [streaming] JobGraphbuilder separated to StreamGraph and StreamingJobGraphGenerator - posted by mb...@apache.org on 2015/01/21 18:53:59 UTC, 0 replies.
- [6/8] flink git commit: [streaming] JobGraphbuilder separated to StreamGraph and StreamingJobGraphGenerator - posted by mb...@apache.org on 2015/01/21 18:54:00 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-1345] [streaming] Added support for chaining operators with directed outputs - posted by mb...@apache.org on 2015/01/21 18:54:01 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-1345] [streaming] Chaining refactor + ChainingStrategy exposed through the API for operators - posted by mb...@apache.org on 2015/01/21 18:54:02 UTC, 0 replies.
- svn commit: r1653630 - in /flink: ./ _includes/ _posts/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/docs/0.6-incubating/ site/docs/0.6-incubating/api/java/org/apache/flink/addons/ site/docs/0.6-incubating/api/java/org/apache/flin... - posted by rm...@apache.org on 2015/01/21 20:24:13 UTC, 0 replies.
- flink git commit: [docs] Update URLs for the release - posted by rm...@apache.org on 2015/01/21 21:55:10 UTC, 0 replies.
- flink git commit: [FLINK-1372] [runtime] Adds EnvironmentInformation.logEnvironmentInfo method calls to JobManager's and TaskManager's main methods. - posted by tr...@apache.org on 2015/01/22 12:09:00 UTC, 0 replies.
- flink git commit: [Runtime] Fix unnecessary object creation for large record sorter - posted by uc...@apache.org on 2015/01/22 12:26:54 UTC, 0 replies.
- [1/2] flink git commit: Cleanup missing space =) - posted by hs...@apache.org on 2015/01/23 00:23:01 UTC, 0 replies.
- [2/2] flink git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/flink into asf_master - posted by hs...@apache.org on 2015/01/23 00:23:02 UTC, 0 replies.
- [1/2] flink git commit: Rename coGroupDataSet.scala to CoGroupDataSet.scala, and crossDataSet.scala to CrossDataSet.scala - posted by hs...@apache.org on 2015/01/23 02:40:38 UTC, 0 replies.
- [2/2] flink git commit: Move the UnfinishedCoGroupOperation class into its own Scala file. - posted by hs...@apache.org on 2015/01/23 02:40:39 UTC, 0 replies.
- flink git commit: [FLINK-1353] [runtime] Loops through the JobManager's timeout to the Execution objects. - posted by tr...@apache.org on 2015/01/23 11:10:22 UTC, 0 replies.
- flink git commit: [tests] Fix missing task parallelism in JobManagerITCase bipartite job support test - posted by uc...@apache.org on 2015/01/23 12:07:02 UTC, 0 replies.
- flink git commit: [quickstart] Set quickstart.sh version to latest release (0.8.0) - posted by rm...@apache.org on 2015/01/23 16:49:51 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-1385] Make resource avilability checks optional (warn instead of fail) - posted by rm...@apache.org on 2015/01/23 18:43:54 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-1295] Address pull request review comments - posted by rm...@apache.org on 2015/01/23 18:43:55 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - posted by rm...@apache.org on 2015/01/23 18:43:56 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - posted by rm...@apache.org on 2015/01/23 18:43:57 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - posted by rm...@apache.org on 2015/01/23 18:43:58 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - posted by rm...@apache.org on 2015/01/23 18:43:59 UTC, 0 replies.
- flink git commit: [FLINK-1406] [documentation] update compatibility notice with link to further documentation - posted by fh...@apache.org on 2015/01/23 22:21:56 UTC, 0 replies.
- svn commit: r1654577 - in /flink/site/docs/0.8: img/plan_visualizer.png programming_guide.html - posted by se...@apache.org on 2015/01/24 22:16:34 UTC, 0 replies.
- flink git commit: [FLINK-1440] [docs] Fix missing plan visualizer image. - posted by se...@apache.org on 2015/01/24 22:18:42 UTC, 1 replies.
- svn commit: r1654660 - in /flink: how-to-contribute.md site/how-to-contribute.html - posted by rm...@apache.org on 2015/01/25 15:49:55 UTC, 0 replies.
- svn commit: r1654661 - in /flink: how-to-contribute.md site/how-to-contribute.html - posted by rm...@apache.org on 2015/01/25 15:57:04 UTC, 0 replies.
- svn commit: r1654662 - in /flink: community.md site/community.html - posted by rm...@apache.org on 2015/01/25 16:13:36 UTC, 0 replies.
- flink git commit: [FLINK-1381] Allow multiple output splitters for single stream operator - posted by gy...@apache.org on 2015/01/25 17:41:16 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1081] Add getPos() method into FSDataInputStream class - posted by gy...@apache.org on 2015/01/25 22:11:11 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1081] Add HDFS file-stream source for streaming - posted by gy...@apache.org on 2015/01/25 22:11:12 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1081] FileMonitoringFunction fix for proper handling of modification times - posted by gy...@apache.org on 2015/01/25 22:11:13 UTC, 0 replies.
- flink git commit: [streaming] Fix bug with operators inheriting lower parallelism - posted by gy...@apache.org on 2015/01/26 10:17:25 UTC, 0 replies.
- flink git commit: [docs] Address comment from outdated github pull request This is the comment: https://github.com/apache/flink/pull/295#discussion_r22783345 The pull request has been merged through a different commit. - posted by rm...@apache.org on 2015/01/26 10:58:36 UTC, 0 replies.
- flink git commit: [FLINK-1425] [streaming] Add scheduling of all tasks at once - posted by uc...@apache.org on 2015/01/26 11:13:26 UTC, 0 replies.
- flink git commit: [FLINK-1389] Allow changing the filenames of the files created when writing to a directory - posted by rm...@apache.org on 2015/01/26 11:30:06 UTC, 1 replies.
- flink git commit: [FLINK-1428] [docs] Fix typos in Java code example for RichGroupReduceFunction [ci skip] - posted by uc...@apache.org on 2015/01/26 13:40:45 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-1168] Add support for multi-char field delimiters in CSVInputFormats. This commit includes parts of Cbro's pull request and subsumes PR #247 - posted by fh...@apache.org on 2015/01/26 14:51:59 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1168] Add support for multi-char field delimiters in CSVInputFormats. This commit includes parts of Cbro's pull request and subsumes PR #247 - posted by fh...@apache.org on 2015/01/26 14:52:00 UTC, 0 replies.
- flink git commit: [FLINK-1453] Fix failing flink-yarn-tests on OS X - posted by rm...@apache.org on 2015/01/26 15:44:30 UTC, 0 replies.
- flink git commit: [FLINK-1446] Fix Kryo createInstance() method - posted by rm...@apache.org on 2015/01/26 16:18:08 UTC, 1 replies.
- flink git commit: [FLINK-1147][Java API] TypeInference on POJOs - posted by tw...@apache.org on 2015/01/26 16:29:10 UTC, 0 replies.
- svn commit: r1654997 - in /flink: community.md site/community.html site/docs/0.8/programming_guide.html - posted by rm...@apache.org on 2015/01/27 11:23:05 UTC, 0 replies.
- flink git commit: [FLINK-1433] Add HADOOP_CLASSPATH to start scripts This closes #337 - posted by rm...@apache.org on 2015/01/27 12:19:46 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-1352] [runtime] Fix buggy registration of TaskManager to JobManager by introducing dedicated RefusedRegistration messages - posted by tr...@apache.org on 2015/01/27 14:49:34 UTC, 0 replies.
- [2/2] flink git commit: [runtime tests] Fix buggy recover a task manager failure integration test case - posted by tr...@apache.org on 2015/01/27 14:49:35 UTC, 0 replies.
- flink git commit: [streaming] Refactor iterative datastream for clear self-contained functionality - posted by gy...@apache.org on 2015/01/27 22:32:45 UTC, 0 replies.
- flink git commit: [FLINK-1434] [FLINK-1401] Streaming support added for webclient - posted by gy...@apache.org on 2015/01/28 00:30:25 UTC, 0 replies.
- [01/13] flink git commit: [FLINK-1328] Integrated forwarded Fields into the optimizer (incomplete) - posted by fh...@apache.org on 2015/01/28 02:24:01 UTC, 0 replies.
- [02/13] flink git commit: [FLINK-1328] Integrated forwarded Fields into the optimizer (incomplete) - posted by fh...@apache.org on 2015/01/28 02:24:02 UTC, 0 replies.
- [03/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:03 UTC, 0 replies.
- [04/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:04 UTC, 0 replies.
- [05/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:05 UTC, 0 replies.
- [06/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:06 UTC, 0 replies.
- [07/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:07 UTC, 0 replies.
- [08/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:08 UTC, 0 replies.
- [09/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:09 UTC, 0 replies.
- [10/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:10 UTC, 0 replies.
- [11/13] flink git commit: [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions. - Renamed constantField annotations to forwardedFields annotation - Forwarded fields can be defined for (nested) tuples, Po - posted by fh...@apache.org on 2015/01/28 02:24:11 UTC, 0 replies.
- [12/13] flink git commit: [FLINK-1328] Added previously failing semantic annotations to examples and fixed them by enabling partitioning on AtomicTypes. - posted by fh...@apache.org on 2015/01/28 02:24:12 UTC, 0 replies.
- [13/13] flink git commit: [FLINK-1328] [docs] Updated documentation of semantic properties. Improved documentation of key specification and data type. - posted by fh...@apache.org on 2015/01/28 02:24:13 UTC, 0 replies.
- [1/2] flink git commit: [Typo] Delete DiscardingOuputFormat - posted by fh...@apache.org on 2015/01/28 02:42:00 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1457] [build] Exclude avro test file from RAT check - posted by fh...@apache.org on 2015/01/28 02:42:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1344] [streaming] [scala] Added implicits from scala seq to datastream and static StreamExecutionEnvironment initialization - posted by gy...@apache.org on 2015/01/28 15:14:18 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1344] [streaming] Quickfix for the recent webclient support - posted by gy...@apache.org on 2015/01/28 15:14:19 UTC, 0 replies.
- svn commit: r1655562 - in /flink/site/docs: 0.8/setup_quickstart.html index.html - posted by uc...@apache.org on 2015/01/29 10:49:01 UTC, 0 replies.
- flink git commit: Remove semicolon in Scala files. Fix java doc alignment in AggregatorsITCase.java - posted by hs...@apache.org on 2015/01/29 23:06:22 UTC, 0 replies.
- flink git commit: [FLINK-1460] fix typos - posted by hs...@apache.org on 2015/01/30 18:51:36 UTC, 0 replies.
- flink git commit: [FLINK-1425] [streaming] Non-lazy scheduling set for streaming programs - posted by gy...@apache.org on 2015/01/31 11:11:20 UTC, 0 replies.