You are viewing a plain text version of this content. The canonical link for it is here.
- flink git commit: [Typo] Typo fixes in code comments. - posted by fh...@apache.org on 2015/02/01 21:49:42 UTC, 0 replies.
- flink git commit: [FLINK-1419] [runtime] Fix: distributed cache properly synchronized - posted by fh...@apache.org on 2015/02/02 00:41:12 UTC, 0 replies.
- [01/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:39 UTC, 0 replies.
- [02/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:40 UTC, 0 replies.
- [03/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:41 UTC, 0 replies.
- [04/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:42 UTC, 0 replies.
- [05/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:43 UTC, 0 replies.
- [06/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:44 UTC, 0 replies.
- [07/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:45 UTC, 0 replies.
- [08/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:46 UTC, 0 replies.
- [09/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:47 UTC, 0 replies.
- [10/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:48 UTC, 0 replies.
- [11/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:49 UTC, 0 replies.
- [12/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:50 UTC, 0 replies.
- [13/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:51 UTC, 0 replies.
- [14/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:52 UTC, 0 replies.
- [15/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:53 UTC, 0 replies.
- [16/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:54 UTC, 0 replies.
- [17/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:55 UTC, 0 replies.
- [18/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:56 UTC, 0 replies.
- [19/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:57 UTC, 0 replies.
- [20/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:58 UTC, 0 replies.
- [21/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:41:59 UTC, 0 replies.
- [22/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:00 UTC, 0 replies.
- [23/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:01 UTC, 0 replies.
- [24/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:02 UTC, 0 replies.
- [25/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:03 UTC, 0 replies.
- [26/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:04 UTC, 0 replies.
- [27/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:05 UTC, 0 replies.
- [28/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:06 UTC, 0 replies.
- [29/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:07 UTC, 0 replies.
- [30/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:08 UTC, 0 replies.
- [31/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:09 UTC, 0 replies.
- [32/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:10 UTC, 0 replies.
- [33/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:11 UTC, 0 replies.
- [34/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:12 UTC, 0 replies.
- [35/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:13 UTC, 0 replies.
- [36/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:14 UTC, 0 replies.
- [37/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:15 UTC, 0 replies.
- [38/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:16 UTC, 0 replies.
- [39/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:17 UTC, 0 replies.
- [40/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:18 UTC, 0 replies.
- [41/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:19 UTC, 0 replies.
- [42/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:20 UTC, 0 replies.
- [43/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:21 UTC, 0 replies.
- [44/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:22 UTC, 0 replies.
- [45/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:23 UTC, 0 replies.
- [46/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:24 UTC, 0 replies.
- [47/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:25 UTC, 0 replies.
- [48/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:26 UTC, 0 replies.
- [49/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:27 UTC, 0 replies.
- [50/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:28 UTC, 0 replies.
- [51/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging' - posted by rm...@apache.org on 2015/02/02 19:42:29 UTC, 0 replies.
- [52/52] flink git commit: [FLINK-1452] Add 'flink-contrib' module - posted by rm...@apache.org on 2015/02/02 19:42:30 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1105] [api-extending] Add support for local sorting on data sinks. - posted by fh...@apache.org on 2015/02/03 11:12:39 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1105] [docs] Added documentation for locally sorted output - posted by fh...@apache.org on 2015/02/03 11:12:40 UTC, 0 replies.
- [1/9] flink git commit: Improved exception for missing type of InputFormat - posted by se...@apache.org on 2015/02/03 13:23:40 UTC, 0 replies.
- [2/9] flink git commit: [misc] Code cleanups and fixes for various compiler warnings - posted by se...@apache.org on 2015/02/03 13:23:41 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values - posted by se...@apache.org on 2015/02/03 13:23:42 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-1193][java-api][scala-api] Complete support for multidimensional arrays - posted by se...@apache.org on 2015/02/03 13:23:43 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-1193][java-api][scala-api] Fix copy method for ObjectArraySerializer - posted by se...@apache.org on 2015/02/03 13:23:44 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-1464] [java-api] Added ResultTypeQueryable interface implementation to TypeSerializerInputFormat. - posted by se...@apache.org on 2015/02/03 13:23:45 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-1165] [java-api] Add createCollectionsEnvironment to Java API - posted by se...@apache.org on 2015/02/03 13:23:46 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-1165] [java-api] Rename "createCollectionEnvironment" to not break existing APIs. - posted by se...@apache.org on 2015/02/03 13:23:47 UTC, 0 replies.
- [9/9] flink git commit: [java api] Fix various compiler warnings through code cleanups - posted by se...@apache.org on 2015/02/03 13:23:48 UTC, 0 replies.
- flink git commit: [FLINK-1330] [build] Build creates a link in the root directory to the build target directory - posted by se...@apache.org on 2015/02/03 14:39:26 UTC, 0 replies.
- [1/2] flink git commit: [scripts] Fix job manager heap size configuration key - posted by uc...@apache.org on 2015/02/03 17:13:39 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1468] [scripts] Add integer check for job/task manager heap size config values - posted by uc...@apache.org on 2015/02/03 17:13:40 UTC, 0 replies.
- svn commit: r1656952 - in /flink: community.md index.html site/blog/feed.xml site/community.html site/index.html - posted by hs...@apache.org on 2015/02/04 00:54:09 UTC, 0 replies.
- svn commit: r1657113 - /flink/site/docs/latest - posted by uc...@apache.org on 2015/02/04 11:41:35 UTC, 0 replies.
- flink git commit: [FLINK-1468] [scripts] Cancel job/task manager startup when misconfigured heap sizes - posted by uc...@apache.org on 2015/02/04 14:14:32 UTC, 0 replies.
- svn commit: r1657217 - in /flink: _posts/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2015/02/ site/news/2015/02/04/ - posted by kt...@apache.org on 2015/02/04 14:41:13 UTC, 0 replies.
- svn commit: r1657233 - in /flink: _posts/2015-02-04-january-in-flink.md site/blog/feed.xml site/blog/index.html site/news/2015/02/04/january-in-flink.html - posted by kt...@apache.org on 2015/02/04 14:50:59 UTC, 0 replies.
- flink git commit: [streaming] Task chaining bugfix for partitioner settings - posted by gy...@apache.org on 2015/02/04 15:17:23 UTC, 0 replies.
- flink git commit: [FLINK-1473] Simplify SplittableIterator interface - posted by rm...@apache.org on 2015/02/04 15:21:57 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-592] Address pull request comments: fail early on missing auth, load log4j-cli.properties and do not set 'default' as default queue - posted by rm...@apache.org on 2015/02/04 15:57:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-592] Add support for Kerberos secured YARN setups to Flink. - posted by rm...@apache.org on 2015/02/04 15:57:50 UTC, 0 replies.
- svn commit: r1657446 - in /flink: community.md site/blog/feed.xml site/community.html - posted by hs...@apache.org on 2015/02/05 01:12:28 UTC, 0 replies.
- svn commit: r1657447 - /flink/site/downloads.html - posted by hs...@apache.org on 2015/02/05 01:12:52 UTC, 0 replies.
- flink git commit: [FLINK-1477] Respect HADOOP_HOME when starting Flink - posted by rm...@apache.org on 2015/02/05 11:15:21 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-1318] [docs] Added documentation for CSV parsing options. - posted by fh...@apache.org on 2015/02/05 11:31:20 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1318] [api-breaking] Simplified quoted string parsing, made it optional, and use a configurable quote character - posted by fh...@apache.org on 2015/02/05 11:31:21 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1443 [api-breaking] Extended split assigner interface by parallel task id. - posted by fh...@apache.org on 2015/02/05 11:31:22 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1443] Added support for replicated data sources. Introduced new PartitioningProperty for any distribution (random partitioning or full replication). - posted by fh...@apache.org on 2015/02/05 11:31:23 UTC, 0 replies.
- [1/3] flink git commit: Fix typo in task manager startup temp directory check log message - posted by uc...@apache.org on 2015/02/05 11:56:52 UTC, 0 replies.
- [2/3] flink git commit: Log blob cache and server storage directories at startup - posted by uc...@apache.org on 2015/02/05 11:56:53 UTC, 0 replies.
- [3/3] flink git commit: Ensure blob manager storage directory creation is successful - posted by uc...@apache.org on 2015/02/05 11:56:54 UTC, 0 replies.
- [1/2] flink git commit: Ensure blob manager storage directory creation is successful - posted by uc...@apache.org on 2015/02/05 12:01:40 UTC, 0 replies.
- [2/2] flink git commit: Log blob cache and server storage directories at startup - posted by uc...@apache.org on 2015/02/05 12:01:41 UTC, 0 replies.
- flink git commit: [FLINK-1458] Allow Interfaces and abstract types in TypeExtractor - posted by al...@apache.org on 2015/02/05 12:03:37 UTC, 0 replies.
- svn commit: r1657551 [1/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [9/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [6/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [8/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [3/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [2/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [7/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [4/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- svn commit: r1657551 [5/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/ - posted by rm...@apache.org on 2015/02/05 13:21:40 UTC, 0 replies.
- [1/7] flink git commit: [scala api] Minor code cleanup for compiler warnings - posted by se...@apache.org on 2015/02/05 13:25:42 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-1415] [runtime] Clean up archiving of ExecutionGraphs - posted by se...@apache.org on 2015/02/05 13:25:43 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-1442] [runtime] Reduce memory consumption of archived execution graph - posted by se...@apache.org on 2015/02/05 13:25:44 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-1442] [runtime] Minor code cleanups in MemoryArchivist - posted by se...@apache.org on 2015/02/05 13:25:45 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by se...@apache.org on 2015/02/05 13:25:46 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by se...@apache.org on 2015/02/05 13:25:47 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by se...@apache.org on 2015/02/05 13:25:48 UTC, 0 replies.
- flink git commit: [docs] add documentation for FLink GCE setup using bdutil - posted by se...@apache.org on 2015/02/05 14:01:43 UTC, 0 replies.
- flink git commit: [FLINK-1479] [runtime] Spawned threads in sorter get the same context class loader as the parent thread - posted by se...@apache.org on 2015/02/05 14:44:57 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-1415] [runtime] Akka cleanups - posted by tr...@apache.org on 2015/02/05 14:59:40 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1415] [runtime] Akka cleanups - posted by tr...@apache.org on 2015/02/05 14:59:41 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1415] [runtime] Akka cleanups - posted by tr...@apache.org on 2015/02/05 14:59:42 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1415] [runtime] Akka cleanups - posted by tr...@apache.org on 2015/02/05 14:59:43 UTC, 0 replies.
- flink git commit: [FLINK-1471][java-api] Fixes wrong input validation if function has no generics - posted by tw...@apache.org on 2015/02/05 15:04:33 UTC, 0 replies.
- flink git commit: [FLINK-1480] Set Hadoop version to 2.6.0 for travis tests - posted by rm...@apache.org on 2015/02/05 16:28:15 UTC, 0 replies.
- [1/2] flink git commit: [runtime] Enables remote communication for local standalone cluster mode which is required by the JobClient. - posted by tr...@apache.org on 2015/02/05 17:56:33 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1481] Fixes flakey JobManagerITCase which relied on non-deterministic behaviour. - posted by tr...@apache.org on 2015/02/05 17:56:34 UTC, 0 replies.
- flink git commit: [FLINK-1482] Add shutdown hooks to delete blob storage directories - posted by uc...@apache.org on 2015/02/05 18:20:27 UTC, 0 replies.
- flink git commit: [FLINK-1482] Log error instead of rethrowing it during shutdown hook - posted by uc...@apache.org on 2015/02/05 18:44:46 UTC, 0 replies.
- [1/4] flink git commit: [runtime] Remove obsolete line reader test classes - posted by se...@apache.org on 2015/02/05 19:27:31 UTC, 0 replies.
- [2/4] flink git commit: [runtime] Increase timeout in pipeline queue tests, to increase test robustness on CI servers - posted by se...@apache.org on 2015/02/05 19:27:32 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1478] [jobmanager] Scheduler support for external location constraints - posted by se...@apache.org on 2015/02/05 19:27:33 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1478] [jobmanager] Stubs to support eager input split assignment on task creation - posted by se...@apache.org on 2015/02/05 19:27:34 UTC, 0 replies.
- flink git commit: [streaming] Critical bugfix for streaming keyselectors - posted by gy...@apache.org on 2015/02/06 12:43:37 UTC, 0 replies.
- flink git commit: [FLINK-1488][yarn] Fix broken log file access - posted by rm...@apache.org on 2015/02/06 14:49:49 UTC, 0 replies.
- flink git commit: [FLINK-1490][fix][java-api] Fix incorrect local output sorting of nested types with field position keys. - posted by fh...@apache.org on 2015/02/06 16:01:43 UTC, 0 replies.
- flink git commit: [FLINK-1485][documentation] Fix typo in Java join function example. - posted by fh...@apache.org on 2015/02/06 16:14:49 UTC, 0 replies.
- [1/2] flink git commit: [docs] Updated legacy references containing 'incubator' substring - posted by mb...@apache.org on 2015/02/06 17:21:43 UTC, 0 replies.
- [2/2] flink git commit: Remove 'incubator-' prefix from README.md. - posted by mb...@apache.org on 2015/02/06 17:21:44 UTC, 0 replies.
- flink git commit: [FLINK-1166] Add qa-check.sh tool - posted by rm...@apache.org on 2015/02/06 17:42:15 UTC, 0 replies.
- [1/3] flink git commit: [streaming] Critical bugfix for streaming keyselectors - posted by mb...@apache.org on 2015/02/06 18:47:35 UTC, 0 replies.
- [2/3] flink git commit: [docs] Updated legacy references containing 'incubator' substring - posted by mb...@apache.org on 2015/02/06 18:47:36 UTC, 0 replies.
- [3/3] flink git commit: Remove 'incubator-' prefix from README.md. - posted by mb...@apache.org on 2015/02/06 18:47:37 UTC, 0 replies.
- flink git commit: [FLINK-1438] [jobmanager] Fix class loading issue for messages with custom input splits - posted by se...@apache.org on 2015/02/06 18:47:53 UTC, 0 replies.
- svn commit: r1657909 - in /flink: _layouts/default.html _posts/2015-02-06-streaming-example.md img/blog/blog_basic_window.png img/blog/blog_data_driven.png img/blog/blog_multi_input.png img/blog/blog_social_media.png img/blog/blog_stream_join.png - posted by mb...@apache.org on 2015/02/06 19:02:46 UTC, 0 replies.
- flink git commit: [streaming] Proper hash join added for window joins - posted by gy...@apache.org on 2015/02/07 17:32:30 UTC, 0 replies.
- flink git commit: [FLINK-1475] Decrease log level for yarn tests - posted by rm...@apache.org on 2015/02/09 11:51:11 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1463] Fix stateful/stateless Serializers and Comparators - posted by al...@apache.org on 2015/02/09 13:32:28 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-1463] Fix stateful/stateless Serializers and Comparators - posted by al...@apache.org on 2015/02/09 13:32:29 UTC, 1 replies.
- svn commit: r1658386 [1/2] - in /flink/site: blog/ blog/page2/ blog/page3/ news/2012/08/21/ news/2012/10/15/ news/2012/11/12/ news/2012/11/21/ news/2013/03/27/ news/2013/10/21/ news/2013/12/13/ news/2014/01/10/ news/2014/01/12/ news/2014/01/13/ news/20... - posted by mb...@apache.org on 2015/02/09 13:34:26 UTC, 0 replies.
- svn commit: r1658386 [2/2] - in /flink/site: blog/ blog/page2/ blog/page3/ news/2012/08/21/ news/2012/10/15/ news/2012/11/12/ news/2012/11/21/ news/2013/03/27/ news/2013/10/21/ news/2013/12/13/ news/2014/01/10/ news/2014/01/12/ news/2014/01/13/ news/20... - posted by mb...@apache.org on 2015/02/09 13:34:26 UTC, 0 replies.
- svn commit: r1658387 [8/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [5/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [3/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [6/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [2/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [7/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [4/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658387 [1/8] - in /flink/site: ./ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/spargel/java/record/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quicks... - posted by mb...@apache.org on 2015/02/09 13:40:45 UTC, 0 replies.
- svn commit: r1658388 [1/2] - in /flink/site/news/2015/02/09: ./ streaming-example.html - posted by mb...@apache.org on 2015/02/09 13:44:50 UTC, 0 replies.
- svn commit: r1658388 [2/2] - in /flink/site/news/2015/02/09: ./ streaming-example.html - posted by mb...@apache.org on 2015/02/09 13:44:50 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by rm...@apache.org on 2015/02/09 13:59:11 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by rm...@apache.org on 2015/02/09 13:59:12 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. - posted by rm...@apache.org on 2015/02/09 13:59:13 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API - posted by al...@apache.org on 2015/02/09 14:42:26 UTC, 1 replies.
- [2/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API - posted by al...@apache.org on 2015/02/09 14:42:27 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API - posted by al...@apache.org on 2015/02/09 14:42:28 UTC, 1 replies.
- [1/4] flink git commit: [backports] Cleanup and port changes to 0.8 branch. - posted by rm...@apache.org on 2015/02/09 14:49:11 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1392] Add Kryo serializer for Protobuf - posted by rm...@apache.org on 2015/02/09 14:49:12 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] Also use java closure cleaner on grouped operations - posted by rm...@apache.org on 2015/02/09 14:49:13 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo - posted by rm...@apache.org on 2015/02/09 14:49:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 1) - posted by se...@apache.org on 2015/02/09 15:55:19 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 2) - posted by se...@apache.org on 2015/02/09 15:55:20 UTC, 0 replies.
- flink git commit: [FLINK-1478] [jobmanager] (addendum) Add eager check for null as input split host name - posted by se...@apache.org on 2015/02/09 15:57:12 UTC, 0 replies.
- flink git commit: [hotfix] Fix missing guava dependency of flink-tests - posted by al...@apache.org on 2015/02/09 17:13:16 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-1498] [tests] Better error messages in external sort tests - posted by se...@apache.org on 2015/02/09 18:54:40 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1498] [tests] Set a minimal JVM size to prevent NIO memory problems - posted by se...@apache.org on 2015/02/09 18:54:41 UTC, 0 replies.
- flink git commit: [FLINK-1495][yarn] Make Akka timeout configurable in YARN client. - posted by rm...@apache.org on 2015/02/09 19:06:47 UTC, 0 replies.
- flink git commit: Remove unused enum values from Aggregations enum. - posted by hs...@apache.org on 2015/02/09 19:24:18 UTC, 0 replies.
- flink git commit: [streaming] Small backport fixes for streaming to branch-0.8 - posted by mb...@apache.org on 2015/02/10 08:50:21 UTC, 0 replies.
- [1/3] flink git commit: [streaming] Java Stock streaming example added - posted by mb...@apache.org on 2015/02/10 08:51:58 UTC, 0 replies.
- [2/3] flink git commit: [streaming] Stock streaming example added - posted by mb...@apache.org on 2015/02/10 08:51:59 UTC, 0 replies.
- [3/3] flink git commit: [streaming] Windowing examples cleanup - posted by mb...@apache.org on 2015/02/10 08:52:00 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - posted by al...@apache.org on 2015/02/10 14:11:11 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - posted by al...@apache.org on 2015/02/10 14:11:12 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - posted by al...@apache.org on 2015/02/10 14:11:13 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - posted by al...@apache.org on 2015/02/10 14:11:14 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - posted by al...@apache.org on 2015/02/10 14:11:15 UTC, 0 replies.
- flink git commit: [FLINK-1492] Fix exceptions on blob store shutdown - posted by rm...@apache.org on 2015/02/10 15:34:00 UTC, 1 replies.
- flink git commit: Commit for release 0.8.1 - posted by rm...@apache.org on 2015/02/10 17:27:14 UTC, 2 replies.
- flink git commit: [FLINK-1496] [distributed runtime] Fix loss of events at uninitialized input channels - posted by uc...@apache.org on 2015/02/11 10:31:26 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-1201] [gelly] first take on neighborhood methods: OutEdges - posted by se...@apache.org on 2015/02/11 11:49:03 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use vertex/edge instead of tuples in the test - posted by se...@apache.org on 2015/02/11 11:49:04 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-1201] [gelly] set joins to sort-merge joins in isWeaklyConnected - posted by se...@apache.org on 2015/02/11 11:49:05 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-1201] [gelly] get rid of Vertex to Tuple2 and Edge to Tuple3 conversions in runVertexCentricIteration - posted by se...@apache.org on 2015/02/11 11:49:06 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-1201] [gelly] [sssp example] only update the vertex value if new distance is smaller - posted by se...@apache.org on 2015/02/11 11:49:07 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-1201] [gelly] SSSP with runVertexCentricIteration - posted by se...@apache.org on 2015/02/11 11:49:08 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed mapVertices to return a Graph and simplified SSSP - posted by se...@apache.org on 2015/02/11 11:49:09 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-1201] [gelly] joinWithVertices implemented and tested - posted by se...@apache.org on 2015/02/11 11:49:10 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-1201] [gelly] return arbitrary type instead of Tuple2 for the neighbor methods - posted by se...@apache.org on 2015/02/11 11:49:11 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed mapEdges to also return a Graph - posted by se...@apache.org on 2015/02/11 11:49:12 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-1201] [gelly] reduceOnNeighbors with vertex value - posted by se...@apache.org on 2015/02/11 11:49:13 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-1201] [gelly] correct graph execution environment in InvalidVertexIdsValidator - posted by se...@apache.org on 2015/02/11 11:49:14 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-1201] [gelly] reduceOnNeighbors without vertex value - posted by se...@apache.org on 2015/02/11 11:49:15 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-1201] [gelly] removed 2-arg Edge constructor - posted by se...@apache.org on 2015/02/11 11:49:16 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added description in GraphMetrics example - posted by se...@apache.org on 2015/02/11 11:49:17 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-1201] [gelly] fix ClassCastException and Type errors in mapVertices; fixes #41 and #46 - posted by se...@apache.org on 2015/02/11 11:49:18 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-1201] [gelly] key and value types shouldn't be static fields; fixed #42 - posted by se...@apache.org on 2015/02/11 11:49:19 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-1201] [gelly] joinWithEdges implemented and tested - posted by se...@apache.org on 2015/02/11 11:49:20 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Fix bug in TestReduceOnNeighborMethods caused by object reuse - posted by se...@apache.org on 2015/02/11 11:49:21 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed pageRank example to use joinWithEdgesOnSource - posted by se...@apache.org on 2015/02/11 11:49:22 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Expose the full Vertex and Edge object in filter functions - posted by se...@apache.org on 2015/02/11 11:49:23 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use type hints for mapVertices, mapEdges and create - posted by se...@apache.org on 2015/02/11 11:49:24 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Updated JavaDoc for Graph class - posted by se...@apache.org on 2015/02/11 11:49:25 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-1201] [gelly] cloned spargel classes - posted by se...@apache.org on 2015/02/11 11:49:26 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed spargel classes to work with Vertex and Edge types - posted by se...@apache.org on 2015/02/11 11:49:27 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-1201] [gelly] remove isUndirected flag; methods will always consider the graph as directed - posted by se...@apache.org on 2015/02/11 11:49:28 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-1201] [gelly] filtering bad records and top track per user - posted by se...@apache.org on 2015/02/11 11:49:29 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-1201] [gelly] replaced create with fromDataSet - posted by se...@apache.org on 2015/02/11 11:49:30 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-1201] [gelly] created fromTupleDataSet() methods - posted by se...@apache.org on 2015/02/11 11:49:31 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use fromTupleDataset method instead of Tuple3ToEdgeMap - posted by se...@apache.org on 2015/02/11 11:49:32 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-1201] [gelly] create similar users graph - posted by se...@apache.org on 2015/02/11 11:49:33 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added label propagation in library - posted by se...@apache.org on 2015/02/11 11:49:34 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-1201] [gelly] LP example update: nodes get their id as initial label; if 2 labels have the same freq, select the one with the highest value - posted by se...@apache.org on 2015/02/11 11:49:35 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [FLINK-1201] [gelly] label propagation example - posted by se...@apache.org on 2015/02/11 11:49:36 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added label propagation step in MusicProfiles - posted by se...@apache.org on 2015/02/11 11:49:37 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-1201] [gelly] updated music profiles example - posted by se...@apache.org on 2015/02/11 11:49:38 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-1201] [gelly] refactored methods for Graph creation - posted by se...@apache.org on 2015/02/11 11:49:39 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase - posted by se...@apache.org on 2015/02/11 11:49:40 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase - posted by se...@apache.org on 2015/02/11 11:49:41 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase - posted by se...@apache.org on 2015/02/11 11:49:42 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed ConstantFields to ForwardedFields - posted by se...@apache.org on 2015/02/11 11:49:43 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests - posted by se...@apache.org on 2015/02/11 11:49:44 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests - posted by se...@apache.org on 2015/02/11 11:49:45 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests - posted by se...@apache.org on 2015/02/11 11:49:46 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors - posted by se...@apache.org on 2015/02/11 11:49:47 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors - posted by se...@apache.org on 2015/02/11 11:49:48 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors - posted by se...@apache.org on 2015/02/11 11:49:49 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors - posted by se...@apache.org on 2015/02/11 11:49:50 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors - posted by se...@apache.org on 2015/02/11 11:49:51 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added missing javadocs - posted by se...@apache.org on 2015/02/11 11:49:52 UTC, 0 replies.
- flink git commit: [FLINK-1473] Make abstract methods public in SplittableIterator - posted by rm...@apache.org on 2015/02/11 13:27:37 UTC, 0 replies.
- flink git commit: [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet - posted by tr...@apache.org on 2015/02/11 15:17:15 UTC, 0 replies.
- flink git commit: [FLINK-1455] [runtime] Improve robustness of external sorting test errors - posted by se...@apache.org on 2015/02/11 16:34:44 UTC, 0 replies.
- flink git commit: [FLINK-1489] Replaces blocking scheduleOrUpdateConsumers message calls with asynchronous futures. Buffers PartitionInfos at the JobManager in case that the respective consumer has not been scheduled. - posted by rm...@apache.org on 2015/02/11 17:34:44 UTC, 0 replies.
- flink git commit: [FLINK-1504] support for secure HDFS access using kerberos - posted by rm...@apache.org on 2015/02/11 18:23:09 UTC, 0 replies.
- flink git commit: [FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to log level WARNING. - posted by tr...@apache.org on 2015/02/11 18:56:04 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration - posted by se...@apache.org on 2015/02/11 20:43:23 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1530] Cache deserialized ExecutionConfig in the AbstractInvokable - posted by se...@apache.org on 2015/02/11 20:43:24 UTC, 0 replies.
- [3/3] flink git commit: [tests fix] Fix runtime exceptions for large record sorter by properly mocking the environment. - posted by se...@apache.org on 2015/02/11 20:43:25 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1438] [jobmanager] Fix class loading issue for messages with custom input splits - posted by se...@apache.org on 2015/02/11 22:04:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration - posted by se...@apache.org on 2015/02/11 22:04:47 UTC, 0 replies.
- flink git commit: [FLINK-1411] Fix standalone plan visualizer - posted by se...@apache.org on 2015/02/11 22:10:23 UTC, 0 replies.
- [1/2] flink git commit: [webclient] Remove obsolete arrow images - posted by se...@apache.org on 2015/02/11 22:14:05 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1411] Fix standalone plan visualizer - posted by se...@apache.org on 2015/02/11 22:14:06 UTC, 0 replies.
- flink git commit: [FLINK-1504] Fix YARN tests - posted by rm...@apache.org on 2015/02/12 09:12:10 UTC, 0 replies.
- flink git commit: [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values - posted by se...@apache.org on 2015/02/12 09:42:04 UTC, 0 replies.
- flink git commit: Update LICENSE and NOTICE files for release 0.8.1 - posted by se...@apache.org on 2015/02/12 10:49:13 UTC, 0 replies.
- flink git commit: [FLINK-1432] [runtime] Make memory segment release robust against concurrent modifications of the collection - posted by se...@apache.org on 2015/02/12 12:19:59 UTC, 0 replies.
- flink git commit: [runtime] Fixes re-submission of a job by JobClient - posted by tr...@apache.org on 2015/02/12 14:18:31 UTC, 0 replies.
- flink git commit: [FLINK-1510] Make AvroInputFormat splittable - posted by rm...@apache.org on 2015/02/12 14:21:35 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1391] Register common Avro types at Kryo - posted by rm...@apache.org on 2015/02/12 15:39:58 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1510] Make AvroInputFormat splittable - posted by rm...@apache.org on 2015/02/12 15:39:59 UTC, 0 replies.
- Git Push Summary - posted by rm...@apache.org on 2015/02/12 15:48:31 UTC, 1 replies.
- flink git commit: [FLINK-1436] usability improvements to the CliFrontend - posted by mx...@apache.org on 2015/02/12 16:30:57 UTC, 0 replies.
- flink git commit: [FLINK-1436] adapt all CliFrontend test cases - posted by mx...@apache.org on 2015/02/12 17:17:25 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1531] [runtime] Adds proper EOFException forwarding to KryoSerializer. - posted by tr...@apache.org on 2015/02/12 18:21:36 UTC, 1 replies.
- [2/2] flink git commit: [avro] Cleaning up project structure - posted by tr...@apache.org on 2015/02/12 18:21:37 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1533] [runtime] Fixes NPE in the scheduler where the allocated shared slots are not properly checked. - posted by tr...@apache.org on 2015/02/12 18:40:06 UTC, 0 replies.
- flink git commit: [build system] Add rat ignores for generated files - posted by rm...@apache.org on 2015/02/12 19:27:11 UTC, 0 replies.
- flink git commit: [build tools] Improve release scripts - posted by rm...@apache.org on 2015/02/12 19:51:02 UTC, 0 replies.
- flink git commit: [FLINK-1436] fix missing checks in CliFrontendInfoTest - posted by mx...@apache.org on 2015/02/13 12:20:47 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1517] [streaming] Added indexed input iterator for streaming - posted by mb...@apache.org on 2015/02/13 14:58:41 UTC, 0 replies.
- [2/2] flink git commit: [streaming] Added ITCase for streaming classloading - posted by mb...@apache.org on 2015/02/13 14:58:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1529] [jobmanager] Improve error handling on JobManager startup - posted by se...@apache.org on 2015/02/13 17:29:01 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1532] [tests] Fix spurious failure in AggregatorsITCase (plus minor cleanups) - posted by se...@apache.org on 2015/02/13 17:29:02 UTC, 0 replies.
- [1/2] flink git commit: Small cleanups to add space between if-else keyword and parentheses to be consistent as I found them. - posted by hs...@apache.org on 2015/02/13 18:14:30 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/02/13 18:14:31 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1508] [runtime] Removes AkkaUtil.ask and replaces respective calls with explicit future handling. - posted by tr...@apache.org on 2015/02/14 18:10:32 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1543] [runtime] Adds try and catch blocks around all method calls from an actor's receive method which can throw an exception. Sets the StoppingSupervisorStrategy as default for all guardians. - posted by tr...@apache.org on 2015/02/14 18:10:33 UTC, 0 replies.
- flink git commit: [FLINK-1179] [jobmanager] Add button to JobManager web interface to request stack trace of a TaskManager - posted by rm...@apache.org on 2015/02/14 21:05:38 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1545] [runtime][tests] Fixes AsynchronousFileIOChannelsTest.testExceptionForwardsToClose by introducing additional error check in AsynchronousFileIOChannel.close method - posted by se...@apache.org on 2015/02/15 19:33:24 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1487] [runtime][tests] Fixes SchedulerIsolatedTasksTest.testScheduleQueueing by waiting for the released resources to registered at the Scheduler again. - posted by se...@apache.org on 2015/02/15 19:33:25 UTC, 0 replies.
- flink git commit: [FLINK-1551] [runtime] Fix wrong class cast in JobManagerInfoServlet - posted by tr...@apache.org on 2015/02/16 09:55:24 UTC, 0 replies.
- flink git commit: Fix standalone plan visualizer - posted by se...@apache.org on 2015/02/16 13:22:14 UTC, 0 replies.
- [01/20] flink git commit: [streaming] StreamDiscretizer rework to support only 1 eviction and trigger for robustness + test cleanup - posted by mb...@apache.org on 2015/02/16 15:25:27 UTC, 0 replies.
- [02/20] flink git commit: [streaming] StreamDiscretizer rework to support only 1 eviction and trigger for robustness + test cleanup - posted by mb...@apache.org on 2015/02/16 15:25:28 UTC, 0 replies.
- [03/20] flink git commit: [FLINK-1176] [streaming] WindowedDataStream rework for new windowing runtime - posted by mb...@apache.org on 2015/02/16 15:25:29 UTC, 0 replies.
- [04/20] flink git commit: [FLINK-1176] [streaming] WindowedDataStream rework for new windowing runtime - posted by mb...@apache.org on 2015/02/16 15:25:30 UTC, 0 replies.
- [05/20] flink git commit: [FLINK-1176] [streaming] Added invokables for modular windowing tranformations - posted by mb...@apache.org on 2015/02/16 15:25:31 UTC, 0 replies.
- [06/20] flink git commit: [streaming] StreamWindow abstraction added with typeinfo and tests - posted by mb...@apache.org on 2015/02/16 15:25:32 UTC, 0 replies.
- [07/20] flink git commit: [FLINK-1231] [streaming] More sophisticated streaming classloader ITCase - posted by mb...@apache.org on 2015/02/16 15:25:33 UTC, 0 replies.
- [08/20] flink git commit: [streaming] Reimplemented StreamWindow.split to avoid dependency issues - posted by mb...@apache.org on 2015/02/16 15:25:34 UTC, 0 replies.
- [09/20] flink git commit: [streaming] Test cases added for all new windowing invokables - posted by mb...@apache.org on 2015/02/16 15:25:35 UTC, 0 replies.
- [10/20] flink git commit: [streaming] TumblingGroupedPreReducer added + new tests for windowing - posted by mb...@apache.org on 2015/02/16 15:25:36 UTC, 0 replies.
- [11/20] flink git commit: [streaming] Documentations updated to match the reworked windowing semantics - posted by mb...@apache.org on 2015/02/16 15:25:37 UTC, 0 replies.
- [12/20] flink git commit: [streaming] Streaming scala api fix for window changes + example cleanup - posted by mb...@apache.org on 2015/02/16 15:25:38 UTC, 0 replies.
- [13/20] flink git commit: [streaming] GroupedTimeDiscretizer added for lighter time policy thread management - posted by mb...@apache.org on 2015/02/16 15:25:39 UTC, 0 replies.
- [14/20] flink git commit: [streaming] WindowBuffer interface added for preaggregator logic + simple tumbling prereducer - posted by mb...@apache.org on 2015/02/16 15:25:40 UTC, 0 replies.
- [15/20] flink git commit: [streaming] WindowMapFunction added + Streaming package structure cleanup - posted by mb...@apache.org on 2015/02/16 15:25:41 UTC, 0 replies.
- [16/20] flink git commit: [streaming] WindowMapFunction added + Streaming package structure cleanup - posted by mb...@apache.org on 2015/02/16 15:25:42 UTC, 0 replies.
- [17/20] flink git commit: [streaming] WindowMapFunction added + Streaming package structure cleanup - posted by mb...@apache.org on 2015/02/16 15:25:43 UTC, 0 replies.
- [18/20] flink git commit: [FLINK-1539] [streaming] Remove calls to uninitalized runtimecontexts - posted by mb...@apache.org on 2015/02/16 15:25:44 UTC, 0 replies.
- [19/20] flink git commit: [streaming] Integration test added for windowed operations - posted by mb...@apache.org on 2015/02/16 15:25:45 UTC, 0 replies.
- [20/20] flink git commit: [docs] [streaming] Documentation updates for stream windowing - posted by mb...@apache.org on 2015/02/16 15:25:46 UTC, 0 replies.
- svn commit: r1660143 - in /flink: _posts/2015-02-09-streaming-example.md site/blog/index.html site/news/2015/02/09/streaming-example.html - posted by mb...@apache.org on 2015/02/16 16:36:48 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager - posted by se...@apache.org on 2015/02/16 20:40:27 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1559] [akka] Normalize all akka URLs to use IP addresses rather than hostnames - posted by se...@apache.org on 2015/02/16 20:40:28 UTC, 0 replies.
- [3/3] flink git commit: [core] [java api] Various code cleanup and fixed for warnings. - posted by se...@apache.org on 2015/02/16 20:40:29 UTC, 0 replies.
- flink git commit: [FLINK-1542] Test case at BlobUtilsTest should not assume user could not create new item in root directory - posted by se...@apache.org on 2015/02/16 20:54:06 UTC, 0 replies.
- flink git commit: [tests] Fix hostname escaping for older akka versions. - posted by se...@apache.org on 2015/02/16 22:27:05 UTC, 0 replies.
- flink git commit: Fix NullPointerException in TaskManager - posted by rm...@apache.org on 2015/02/17 10:15:42 UTC, 0 replies.
- flink git commit: [FLINK-1557] Move JobManager web frontend server out of JobManager actor - posted by se...@apache.org on 2015/02/17 10:42:57 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1549] [yarn] Adds proper exception handling to YarnJobManager - posted by tr...@apache.org on 2015/02/17 13:17:23 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1554] [runtime] Allows the LocalFlinkMiniCluster to start multiple TaskManager in the same ActorSystem. - posted by tr...@apache.org on 2015/02/17 13:17:24 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1556] [runtime] Corrects faulty JobClient behaviour in case of a submission failure - posted by tr...@apache.org on 2015/02/17 13:17:25 UTC, 0 replies.
- flink git commit: [FLINK-1566] [streaming] Made WindowIntegrationTests thread-safe - posted by gy...@apache.org on 2015/02/17 20:16:46 UTC, 0 replies.
- flink git commit: [FLINK-1574] Fix null RuntimeContext when opening combiner UDF in CombiningUnilateralSortMerger. Move RuntimeContext initialization to begin of RegularPactTask.invoke(). - posted by fh...@apache.org on 2015/02/17 23:25:34 UTC, 0 replies.
- flink git commit: [FLINK-1561] [build system] Use a fresh fork for each integration test run - posted by se...@apache.org on 2015/02/18 12:42:35 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. - posted by se...@apache.org on 2015/02/18 15:05:45 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. - posted by se...@apache.org on 2015/02/18 15:05:46 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-1417] Automatically register types with Kryo - posted by rm...@apache.org on 2015/02/18 16:37:21 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-1417] Automatically register types with Kryo - posted by rm...@apache.org on 2015/02/18 16:37:22 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-1417] Automatically register types with Kryo - posted by rm...@apache.org on 2015/02/18 16:37:23 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-1395] Add support for JodaTime in KryoSerializer - posted by rm...@apache.org on 2015/02/18 16:37:24 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo - posted by rm...@apache.org on 2015/02/18 16:37:25 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-1392] Add Kryo serializer for Protobuf - posted by rm...@apache.org on 2015/02/18 16:37:26 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-1567] Add option to switch between Avro and Kryo serialization - posted by rm...@apache.org on 2015/02/18 16:37:27 UTC, 0 replies.
- flink git commit: [blob manager] Fix flakey test. - posted by se...@apache.org on 2015/02/18 17:44:42 UTC, 0 replies.
- [1/2] flink git commit: Remove extra space after open parenthesis in InstanceConnectionInfo#toString. - posted by se...@apache.org on 2015/02/19 10:36:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown - posted by se...@apache.org on 2015/02/19 10:36:23 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1560][streaming] streaming WordCount ITCases - posted by mb...@apache.org on 2015/02/19 11:42:31 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1560] [streaming] StreamExecutionEnvironment enhancement for ITCases - posted by mb...@apache.org on 2015/02/19 11:42:32 UTC, 0 replies.
- flink git commit: [FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown - posted by se...@apache.org on 2015/02/19 11:54:20 UTC, 0 replies.
- [1/3] flink git commit: [builds] Add logger layout to prefix log output with Maven fork number - posted by uc...@apache.org on 2015/02/19 16:22:18 UTC, 0 replies.
- [2/3] flink git commit: [builds] Print Java process stack traces of stalled builds - posted by uc...@apache.org on 2015/02/19 16:22:19 UTC, 0 replies.
- [3/3] flink git commit: [builds] Allow to upload build artifacts to S3 - posted by uc...@apache.org on 2015/02/19 16:22:20 UTC, 0 replies.
- [1/6] flink git commit: [streaming] Moved WindowingOptimizer to its own class + several minor fixes - posted by gy...@apache.org on 2015/02/19 17:41:22 UTC, 0 replies.
- [2/6] flink git commit: [streaming] Add MultiEvictionPolicy: It wraps around multiple eviction policies and allows to use them at the same time. It supports both, active and not active policies at the same time. Additionally it introduces different evict - posted by gy...@apache.org on 2015/02/19 17:41:23 UTC, 0 replies.
- [3/6] flink git commit: [streaming] WindowBuffer separated from Discretizer for operator sharing + equality checks added for windowing objects - posted by gy...@apache.org on 2015/02/19 17:41:24 UTC, 0 replies.
- [4/6] flink git commit: [streaming] Discretizer sharing added with further window optimzations for better chaining - posted by gy...@apache.org on 2015/02/19 17:41:25 UTC, 0 replies.
- [5/6] flink git commit: [streaming] Added cloneable versions of MultiEvictionPolicy and MultiTriggerPolicy - posted by gy...@apache.org on 2015/02/19 17:41:26 UTC, 0 replies.
- [6/6] flink git commit: [streaming] Add MultiTriggerPolicy: It wraps around multiple triggers and allows to use them at the same time. It supports both, active and not active policies at the same time. - posted by gy...@apache.org on 2015/02/19 17:41:27 UTC, 0 replies.
- svn commit: r8055 - /release/flink/flink-0.8.1/ - posted by rm...@apache.org on 2015/02/19 18:06:07 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-1585] [tests] Fix mini clusters to respect memory and buffer configurations and improve relative memory computation. - posted by se...@apache.org on 2015/02/19 20:53:25 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-1584] [runtime][tests] Fixes TaskManagerFailsITCase by replacing the TestingCluster with a ForkableFlinkMiniCluster - posted by se...@apache.org on 2015/02/19 20:53:26 UTC, 0 replies.
- [3/9] flink git commit: [web frontend] Small UI css class fix - posted by se...@apache.org on 2015/02/19 20:53:27 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-1584] [tests] Move logic for failure detection test cluster into test classes - posted by se...@apache.org on 2015/02/19 20:53:28 UTC, 0 replies.
- [5/9] flink git commit: [tests] Add integration test for restart recovery - posted by se...@apache.org on 2015/02/19 20:53:29 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-1556] [runtime] Fails jobs properly in case of a job submission exception - posted by se...@apache.org on 2015/02/19 20:53:30 UTC, 0 replies.
- [7/9] flink git commit: [Flink-1484] [runtime] JobManager sends an explicit disconnect message to the registered TaskManagers in case of a graceful shutdown. - posted by se...@apache.org on 2015/02/19 20:53:31 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-1499] [runtime] TaskManager sends explicit disconnect message to JobManager in case of shutdown - posted by se...@apache.org on 2015/02/19 20:53:32 UTC, 0 replies.
- [9/9] flink git commit: [tests] Cleanup style and timeouts in recovery restart tests - posted by se...@apache.org on 2015/02/19 20:53:33 UTC, 0 replies.
- flink git commit: Update references in master to 0.8.1 release - posted by rm...@apache.org on 2015/02/20 10:48:40 UTC, 0 replies.
- flink git commit: Update references in 'release-0.8' branch to release 0.8.1 - posted by rm...@apache.org on 2015/02/20 10:50:07 UTC, 0 replies.
- svn commit: r1661087 - in /flink: ./ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/docs/0.6-incubating/api/java/ site/docs/0.6-incubating/api/java/org/apache/flink/addons/hbase/ site/docs/0.6-incubating/api/java/org/apache/flink/ad... - posted by rm...@apache.org on 2015/02/20 11:55:02 UTC, 0 replies.
- [1/3] flink git commit: [blob manager] Fix flakey test. - posted by se...@apache.org on 2015/02/20 13:26:44 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. - posted by se...@apache.org on 2015/02/20 13:26:45 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. - posted by se...@apache.org on 2015/02/20 13:26:46 UTC, 0 replies.
- flink git commit: [tests] Flix flakey SimpleRecoveryITCase - posted by se...@apache.org on 2015/02/20 13:28:54 UTC, 0 replies.
- flink git commit: [FLINK-1451] [streaming] Parallel file source fix + minor windowing fix - posted by gy...@apache.org on 2015/02/20 14:26:39 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-1444][api-extending] Add support for attaching data properties to data sources - posted by fh...@apache.org on 2015/02/20 16:11:47 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs. - posted by fh...@apache.org on 2015/02/20 16:11:48 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1466] Adds HCatInputFormats to read from HCatalog tables. - posted by fh...@apache.org on 2015/02/20 16:11:49 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-1466] Add support for complex types in Flink tuples for HCatInputFormats. - posted by fh...@apache.org on 2015/02/20 16:11:50 UTC, 0 replies.
- svn commit: r1661159 - in /flink: docs/0.6-incubating/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/apache/flink/api/avro/ docs/0.6-incubating/api/java/org/apache/flink/api/avro/class-use/ docs/0.6-incubating/api/java/org/apache/flink... - posted by rm...@apache.org on 2015/02/20 17:51:39 UTC, 0 replies.
- flink git commit: [FLINK-1592] [streaming] StreamGraph refactor to store vertex IDs as Integers - posted by gy...@apache.org on 2015/02/22 10:33:03 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1505] [distributed runtime] Separate reader API from result consumption - posted by uc...@apache.org on 2015/02/23 10:23:10 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-1505] [distributed runtime] Separate reader API from result consumption - posted by uc...@apache.org on 2015/02/23 10:23:11 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-1505] [distributed runtime] Separate reader API from result consumption - posted by uc...@apache.org on 2015/02/23 10:23:12 UTC, 0 replies.
- [1/6] flink git commit: Change translateToDataflow to return Operator - posted by al...@apache.org on 2015/02/23 16:05:25 UTC, 0 replies.
- [2/6] flink git commit: Add methods to CompositeType for querying field types and names - posted by al...@apache.org on 2015/02/23 16:05:26 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-947] Add a declarative Expression API - posted by al...@apache.org on 2015/02/23 16:05:27 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-947] Add a declarative Expression API - posted by al...@apache.org on 2015/02/23 16:05:28 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-947] Add a declarative Expression API - posted by al...@apache.org on 2015/02/23 16:05:29 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-947] Add a declarative Expression API - posted by al...@apache.org on 2015/02/23 16:05:30 UTC, 0 replies.
- flink git commit: [FLINK-1255] Add FAQ entry about Scala API TypeInformation - posted by al...@apache.org on 2015/02/23 16:36:16 UTC, 0 replies.
- flink git commit: Add link to Type Extraction Doc in FAQ entry about Scala Extraction - posted by al...@apache.org on 2015/02/23 16:44:12 UTC, 0 replies.
- flink git commit: [tests] Disables JobManagerFailsITCase and SimpleRecoveryITCase until they are fixed - posted by tr...@apache.org on 2015/02/23 17:35:25 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1515] [gelly] Splitted runVertexCentricIteration into createVertexIteration and runVertexIteration to make VertexCentricIteration object accessible to developers. - posted by va...@apache.org on 2015/02/23 19:00:20 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1515] [gelly] Changed PageRank to use broadcast set provided by numberOfVertices() to read the number of vertices instead of passing it to the constructor. - posted by va...@apache.org on 2015/02/23 19:00:21 UTC, 0 replies.
- svn commit: r1661871 [3/3] - in /flink: q/ site/blog/ site/blog/page2/ site/blog/page3/ site/q/ - posted by rm...@apache.org on 2015/02/24 10:47:46 UTC, 0 replies.
- svn commit: r1661871 [2/3] - in /flink: q/ site/blog/ site/blog/page2/ site/blog/page3/ site/q/ - posted by rm...@apache.org on 2015/02/24 10:47:46 UTC, 0 replies.
- svn commit: r1661871 [1/3] - in /flink: q/ site/blog/ site/blog/page2/ site/blog/page3/ site/q/ - posted by rm...@apache.org on 2015/02/24 10:47:46 UTC, 0 replies.
- svn commit: r1661872 [1/2] - in /flink: _posts/2015-02-06-streaming-example.md site/blog/feed.xml site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html - posted by rm...@apache.org on 2015/02/24 10:51:10 UTC, 0 replies.
- svn commit: r1661872 [2/2] - in /flink: _posts/2015-02-06-streaming-example.md site/blog/feed.xml site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html - posted by rm...@apache.org on 2015/02/24 10:51:10 UTC, 0 replies.
- [1/6] flink git commit: [runtime] Improve error handling when submitting a job to the JobManager - posted by se...@apache.org on 2015/02/24 13:31:08 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-1596] [runtime] Remove space in temp filename - posted by se...@apache.org on 2015/02/24 13:31:09 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-1598] [runtime] Better error message when network serialization of records exceeds java heap space. - posted by se...@apache.org on 2015/02/24 13:31:10 UTC, 0 replies.
- [4/6] flink git commit: [jobmanager] Add a process reaper to kill the JobManager process when the main actor dies. - posted by se...@apache.org on 2015/02/24 13:31:11 UTC, 0 replies.
- [5/6] flink git commit: [tests] Speed up DataSinkTaskTest - posted by se...@apache.org on 2015/02/24 13:31:12 UTC, 0 replies.
- [6/6] flink git commit: [tests] Add process reaping test for TaskManager, improves process reaping test for JobManager. - posted by se...@apache.org on 2015/02/24 13:31:13 UTC, 0 replies.
- flink git commit: Small cleanup to truncate some lines that are too long for easy read of the code. - posted by hs...@apache.org on 2015/02/24 20:13:39 UTC, 0 replies.
- flink git commit: [FLINK-1596] [runtime] Remove space in temp filename - posted by se...@apache.org on 2015/02/24 22:06:44 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1580] [FLINK-1590] [runtime] Various cleanups and improvements in the TaskManager initialization - posted by se...@apache.org on 2015/02/24 22:09:58 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1580] [FLINK-1590] [runtime] Various cleanups and improvements in the TaskManager initialization - posted by se...@apache.org on 2015/02/24 22:09:59 UTC, 0 replies.
- flink git commit: fixed package statement - posted by hs...@apache.org on 2015/02/24 23:27:27 UTC, 0 replies.
- flink git commit: Fix typo in exception message from assiged to assigned in ExecutionJobVertex. - posted by hs...@apache.org on 2015/02/25 01:00:01 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-1606] [tests] Fixes JobManagerFailsITCase for Akka 2.2.1 by setting gate-invalid-address-for = 5s and quarantine-systems-for = off - posted by uc...@apache.org on 2015/02/25 11:12:49 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-1607] [tests] Fixes SimpleRecoveryITCase by rebalancing the data sources so that all mappers receive at least one element - posted by uc...@apache.org on 2015/02/25 11:12:50 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-1604] [runtime] Fixes livelock in PartitionRequestClientFactory.createPartitionRequestClient - posted by uc...@apache.org on 2015/02/25 11:12:51 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-1604] [FLINK-1568] Add initial connect failure test - posted by uc...@apache.org on 2015/02/25 11:12:52 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-1607] [runtime] Moves PartialPartitionInfo from ExecutionVertex to Execution to automatically clear them in case of restart - posted by uc...@apache.org on 2015/02/25 11:12:53 UTC, 0 replies.
- [6/6] flink git commit: Remove unnecessary log level checks - posted by uc...@apache.org on 2015/02/25 11:12:54 UTC, 0 replies.
- flink git commit: [FLINK-1609] FileSystem.getHomeDirectory() - posted by uc...@apache.org on 2015/02/25 11:38:22 UTC, 0 replies.
- flink git commit: [FLINK-1519] Added canceling state to web interface. - posted by uc...@apache.org on 2015/02/25 12:04:39 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1582][streaming] SocketStream minor enhancements - posted by mb...@apache.org on 2015/02/25 13:22:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1582][streaming]Allow SocketStream to reconnect when socket closes. - posted by mb...@apache.org on 2015/02/25 13:22:17 UTC, 0 replies.
- flink git commit: [tests] Remove timeout in PipelinedPartitionQueueTest - posted by uc...@apache.org on 2015/02/25 13:44:14 UTC, 0 replies.
- [1/2] flink git commit: [web client] Fix webclient config forwarding - posted by se...@apache.org on 2015/02/25 15:10:51 UTC, 0 replies.
- [2/2] flink git commit: [tests] Improve debuggability of ProcessReapingTests - posted by se...@apache.org on 2015/02/25 15:10:52 UTC, 0 replies.
- flink git commit: [docs] Fixes jekyll's config to bind to localhost - posted by tr...@apache.org on 2015/02/25 15:24:16 UTC, 0 replies.
- flink git commit: [streaming] Streaming examples dependency fix - posted by mb...@apache.org on 2015/02/26 17:38:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1462][gelly][docs] added gelly guide - posted by va...@apache.org on 2015/02/27 08:05:35 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1462][gelly][docs] improvements and fixed typos - posted by va...@apache.org on 2015/02/27 08:05:36 UTC, 0 replies.
- [1/2] flink git commit: [core] move AbstractID from runtime to core - posted by mx...@apache.org on 2015/02/27 17:11:58 UTC, 0 replies.
- [2/2] flink git commit: [java-api][scala-api] convenience methods count/collect to transfer a DataSet to the client - posted by mx...@apache.org on 2015/02/27 17:11:59 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1586] [streaming] Add support for iterative streaming graphs on JSON generation Closes #432 - posted by gy...@apache.org on 2015/02/28 18:32:27 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1553] [streaming] Reworked Kafka connectors Closes #433 - posted by gy...@apache.org on 2015/02/28 18:32:28 UTC, 0 replies.
- [1/2] flink git commit: [streaming] Add a clean in WindowedDataStream - posted by gy...@apache.org on 2015/02/28 22:32:45 UTC, 0 replies.
- [2/2] flink git commit: [streaming] Several minor cleanups - posted by gy...@apache.org on 2015/02/28 22:32:46 UTC, 0 replies.