commits@flink.apache.org, 2014-12

You are viewing a plain text version of this content. The canonical link for it is here.

- incubator-flink git commit: [FLINK-984] Compiler tests for distinct(). Adopted the old code from @markus-h - posted by rm...@apache.org on 2014/12/01 10:13:23 UTC, 0 replies.
- incubator-flink git commit: [Docs] Fix rendering issue and typo - posted by rm...@apache.org on 2014/12/01 10:25:14 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1292] Allow for longer normalized keys when using composite keys - posted by se...@apache.org on 2014/12/01 18:39:32 UTC, 0 replies.
- incubator-flink git commit: [Java API] [docs] Rephrase Javadoc of minBy/maxBy and link from min/max - posted by uc...@apache.org on 2014/12/01 18:57:17 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1157] Document TaskManager slots and minor fixes. - posted by rm...@apache.org on 2014/12/04 10:00:36 UTC, 0 replies.
- [01/34] incubator-flink git commit: [streaming] Added cosine distance and Euclidean distance as examples for possible delta function implementations. Test cases are included as well. - posted by mb...@apache.org on 2014/12/05 18:26:06 UTC, 0 replies.
- [02/34] incubator-flink git commit: [streaming] Created tumbling eviction policy. This policy evicts always all tuples after a trigger occurred. It can be used to prevent doubled computation between trigger and eviction policies whenever tumbling windows - posted by mb...@apache.org on 2014/12/05 18:26:07 UTC, 0 replies.
- [03/34] incubator-flink git commit: [streaming] Introduced extractor interface to enable flexible handling of arbitrary input data types. - posted by mb...@apache.org on 2014/12/05 18:26:08 UTC, 0 replies.
- [04/34] incubator-flink git commit: [streaming] Added interface for policy helpers. Such helpers will allow to use policy based windowing through a simpler API. - posted by mb...@apache.org on 2014/12/05 18:26:09 UTC, 0 replies.
- [05/34] incubator-flink git commit: [streaming] Introduced a new invokable to allow flexible windowing based on trigger and eviction policies. Additionally created all required policy interfaces. - posted by mb...@apache.org on 2014/12/05 18:26:10 UTC, 0 replies.
- [06/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases. - posted by mb...@apache.org on 2014/12/05 18:26:11 UTC, 0 replies.
- [07/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on data punctuation. (incl. test cases) - posted by mb...@apache.org on 2014/12/05 18:26:12 UTC, 0 replies.
- [08/34] incubator-flink git commit: [streaming] Added extractor implementations for various extractions and conversions. (incl. test cases) - posted by mb...@apache.org on 2014/12/05 18:26:13 UTC, 0 replies.
- [09/34] incubator-flink git commit: [streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases. - posted by mb...@apache.org on 2014/12/05 18:26:14 UTC, 0 replies.
- [10/34] incubator-flink git commit: [streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions. - posted by mb...@apache.org on 2014/12/05 18:26:15 UTC, 0 replies.
- [11/34] incubator-flink git commit: [streaming] Created trigger and eviction policies which calculate a delta between two data points using a given delta function. The policies evict/trigger in case the delta is higher than a specified threshold. (incl. - posted by mb...@apache.org on 2014/12/05 18:26:16 UTC, 0 replies.
- [12/34] incubator-flink git commit: [streaming] Adding unit tests for the grouped windowing invokable. - posted by mb...@apache.org on 2014/12/05 18:26:17 UTC, 0 replies.
- [13/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes - posted by mb...@apache.org on 2014/12/05 18:26:18 UTC, 0 replies.
- [14/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes - posted by mb...@apache.org on 2014/12/05 18:26:19 UTC, 0 replies.
- [15/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes - posted by mb...@apache.org on 2014/12/05 18:26:20 UTC, 0 replies.
- [16/34] incubator-flink git commit: [streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper. - posted by mb...@apache.org on 2014/12/05 18:26:21 UTC, 0 replies.
- [17/34] incubator-flink git commit: [streaming] Windowing API update + package refactor - posted by mb...@apache.org on 2014/12/05 18:26:22 UTC, 0 replies.
- [18/34] incubator-flink git commit: [streaming] Windowing API update + package refactor - posted by mb...@apache.org on 2014/12/05 18:26:23 UTC, 0 replies.
- [19/34] incubator-flink git commit: [streaming] Extractor requirement removed for custom timestamp windowing - posted by mb...@apache.org on 2014/12/05 18:26:24 UTC, 0 replies.
- [20/34] incubator-flink git commit: [streaming] Added test cases for the policy based windowing invokable. - posted by mb...@apache.org on 2014/12/05 18:26:25 UTC, 0 replies.
- [21/34] incubator-flink git commit: [streaming] Window cross API rework - posted by mb...@apache.org on 2014/12/05 18:26:26 UTC, 0 replies.
- [22/34] incubator-flink git commit: [streaming] Window join api rework to support functional style - posted by mb...@apache.org on 2014/12/05 18:26:27 UTC, 0 replies.
- [23/34] incubator-flink git commit: [streaming] Windowing helper API cleanup - posted by mb...@apache.org on 2014/12/05 18:26:28 UTC, 0 replies.
- [24/34] incubator-flink git commit: [streaming] Changed time based windowing policies to make lower boundary excluded and upper boundary included in the windows and adjusted policy test cases respectively. - posted by mb...@apache.org on 2014/12/05 18:26:29 UTC, 0 replies.
- [25/34] incubator-flink git commit: [streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies - posted by mb...@apache.org on 2014/12/05 18:26:30 UTC, 0 replies.
- [26/34] incubator-flink git commit: [streaming] Created several examples for the usage of policy based windowing. - posted by mb...@apache.org on 2014/12/05 18:26:31 UTC, 0 replies.
- [27/34] incubator-flink git commit: [streaming] Introduced grouped windowing invokable, added required cloneable policy interfaces, and adjusted existing windowing invokable to make it usable together with the new grouped windowing invokable. - posted by mb...@apache.org on 2014/12/05 18:26:32 UTC, 0 replies.
- [28/34] incubator-flink git commit: [FLINK-1279] [streaming] Forward partitioning changed to use round-robin method - posted by mb...@apache.org on 2014/12/05 18:26:33 UTC, 0 replies.
- [29/34] incubator-flink git commit: [streaming] Renamed test cases for window and grouped window invokable to be consistent with the invokable names - posted by mb...@apache.org on 2014/12/05 18:26:34 UTC, 0 replies.
- [30/34] incubator-flink git commit: [streaming] Central trigger/eviction API integration + invokable refactor - posted by mb...@apache.org on 2014/12/05 18:26:35 UTC, 0 replies.
- [31/34] incubator-flink git commit: [streaming] Introduced central eviction policies in the grouped window invokable - posted by mb...@apache.org on 2014/12/05 18:26:36 UTC, 0 replies.
- [32/34] incubator-flink git commit: [streaming] Changed GroupedWindowInvokable to always delete groups in case they have an empty element buffer - posted by mb...@apache.org on 2014/12/05 18:26:37 UTC, 0 replies.
- [33/34] incubator-flink git commit: [streaming] Updated javadocs for new windowing semantics - posted by mb...@apache.org on 2014/12/05 18:26:38 UTC, 0 replies.
- [34/34] incubator-flink git commit: [docs] [streaming] Windowing rework documentation update - posted by mb...@apache.org on 2014/12/05 18:26:39 UTC, 0 replies.
- incubator-flink git commit: [scala] Fix non-reuse copy in CaseClassSerializer - posted by al...@apache.org on 2014/12/05 19:21:33 UTC, 0 replies.
- incubator-flink git commit: [scala] Fix TupleSerializerTest for corrected CaseClassSerializer - posted by al...@apache.org on 2014/12/05 20:28:44 UTC, 0 replies.
- svn commit: r1643429 - in /incubator/flink: ./ _includes/ _layouts/ css/ css/fonts/ css/main/ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/ docs/0.6-incubating/api/java/org/apache/ d... - posted by kt...@apache.org on 2014/12/05 22:02:05 UTC, 0 replies.
- svn commit: r1643435 - /incubator/flink/index.html - posted by kt...@apache.org on 2014/12/05 22:07:33 UTC, 0 replies.
- [1/2] incubator-flink git commit: [FLINK-1301] Added Apache license headers to Markdown, HTML, SVG, Python files. Made exceptions for license check plugin more fine-granular. - posted by fh...@apache.org on 2014/12/05 22:33:00 UTC, 0 replies.
- [2/2] incubator-flink git commit: [FLINK-1301] Added Apache license headers to Markdown, HTML, SVG, Python files. Made exceptions for license check plugin more fine-granular. - posted by fh...@apache.org on 2014/12/05 22:33:01 UTC, 0 replies.
- svn commit: r1643518 - in /incubator/flink: index.html site/downloads.html site/index.html - posted by rm...@apache.org on 2014/12/06 11:58:28 UTC, 0 replies.
- [1/2] incubator-flink git commit: [FLINK-1139] Added FinalizeOnMaster hook to run code after the last task of an OutputFormat completed - posted by fh...@apache.org on 2014/12/08 10:30:14 UTC, 0 replies.
- [2/2] incubator-flink git commit: [FLINK-1139] Fixed HadoopOutputFormat to run with DOP > 1 - posted by fh...@apache.org on 2014/12/08 10:30:15 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1139] Updated Hadoop Compatibility documentation - posted by fh...@apache.org on 2014/12/08 10:38:20 UTC, 0 replies.
- svn commit: r1643799 - in /incubator/flink: blog/index.html site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html site/downloads.html - posted by kt...@apache.org on 2014/12/08 13:54:07 UTC, 0 replies.
- svn commit: r1643802 - /incubator/flink/site/downloads.html - posted by rm...@apache.org on 2014/12/08 14:06:35 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1311] [optimizer] Correctly tag static/dynamic path for auxiliary nodes in iterations. - posted by se...@apache.org on 2014/12/09 15:45:13 UTC, 0 replies.
- [1/5] incubator-flink git commit: Updated java 8 package to match flink-examples standards - posted by mb...@apache.org on 2014/12/10 15:30:42 UTC, 0 replies.
- [2/5] incubator-flink git commit: [FLINK-1312] [streaming] OutputSelector changed to SAM-type to allow java 8 lambdas for splitting - posted by mb...@apache.org on 2014/12/10 15:30:43 UTC, 0 replies.
- [3/5] incubator-flink git commit: [streaming] Java 8 WordCount example added for streaming - posted by mb...@apache.org on 2014/12/10 15:30:44 UTC, 0 replies.
- [4/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas - posted by mb...@apache.org on 2014/12/10 15:30:45 UTC, 0 replies.
- [5/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas - posted by mb...@apache.org on 2014/12/10 15:30:46 UTC, 0 replies.
- [1/4] incubator-flink git commit: [FLINK-1316] [web client] Fix plan display for nodes referenced from multiple closures. - posted by se...@apache.org on 2014/12/10 15:50:37 UTC, 0 replies.
- [2/4] incubator-flink git commit: [FLINK-1315] [optimizer] Fix bug in branch tracking logic. - posted by se...@apache.org on 2014/12/10 15:50:38 UTC, 0 replies.
- [3/4] incubator-flink git commit: [FLINK-1315] [optimizer] Extra test reproducing the IllegalStateException bug in bulk iterations. - posted by se...@apache.org on 2014/12/10 15:50:39 UTC, 0 replies.
- [4/4] incubator-flink git commit: [java8] Fix pom.xml to properly work with Eclipse m2e - posted by se...@apache.org on 2014/12/10 15:50:40 UTC, 0 replies.
- [1/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - posted by fh...@apache.org on 2014/12/10 16:50:52 UTC, 0 replies.
- [2/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - posted by fh...@apache.org on 2014/12/10 16:50:53 UTC, 0 replies.
- [3/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - posted by fh...@apache.org on 2014/12/10 16:50:54 UTC, 0 replies.
- [4/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - posted by fh...@apache.org on 2014/12/10 16:50:55 UTC, 0 replies.
- [5/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional - posted by fh...@apache.org on 2014/12/10 16:50:56 UTC, 0 replies.
- [6/6] incubator-flink git commit: [FLINK-1040] Updated JavaDocs and removed deprecated types() calls from examples and tests - posted by fh...@apache.org on 2014/12/10 16:50:57 UTC, 0 replies.
- svn commit: r1644497 - /incubator/flink/index.html - posted by kt...@apache.org on 2014/12/10 18:59:25 UTC, 0 replies.
- incubator-flink git commit: Fixed java quickstart example - posted by rm...@apache.org on 2014/12/10 21:16:17 UTC, 0 replies.
- incubator-flink git commit: [scala] Add withParameters() support for sinks/sources - posted by uc...@apache.org on 2014/12/11 19:16:41 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1310] Change ClosureCleaner Logging to DEBUG - posted by uc...@apache.org on 2014/12/11 19:30:05 UTC, 0 replies.
- incubator-flink git commit: Enable flink-hbase module for hadoop1 build as well. - posted by rm...@apache.org on 2014/12/12 10:37:36 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1302] Make JDBCInputFormat implement the NonParallelInput interface - posted by rm...@apache.org on 2014/12/12 11:38:51 UTC, 0 replies.
- incubator-flink git commit: [FLINK-998] Close TCP connections after destroying logical channels - posted by uc...@apache.org on 2014/12/12 14:17:21 UTC, 0 replies.
- incubator-flink git commit: Exclude docs/_site/** from License Check - posted by al...@apache.org on 2014/12/12 14:44:57 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1287] LocalizableSplitAssigner prefers splits with less degrees of freedom - posted by fh...@apache.org on 2014/12/12 15:57:18 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1208] Enable CsvInputFormats to ignore invalid lines and lines starting with comments - posted by fh...@apache.org on 2014/12/12 16:50:05 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1324] [runtime] Trailing data is cached before the local input strategies are closed. - posted by se...@apache.org on 2014/12/14 16:40:16 UTC, 0 replies.
- [1/4] incubator-flink git commit: [FLINK-1322] Make Scala API respect WriteMode set in Config - posted by se...@apache.org on 2014/12/14 23:26:30 UTC, 0 replies.
- [2/4] incubator-flink git commit: [scala] Change ScalaAggregateOperator to use TypeSerializer - posted by se...@apache.org on 2014/12/14 23:26:31 UTC, 0 replies.
- [3/4] incubator-flink git commit: [misc] Fix/suppress various compiler warnings. - posted by se...@apache.org on 2014/12/14 23:26:32 UTC, 0 replies.
- [4/4] incubator-flink git commit: [FLINK-1305] [FLINK-1304] Test for HadoopInputWrapper and NullWritable support - posted by se...@apache.org on 2014/12/14 23:26:33 UTC, 0 replies.
- [1/2] incubator-flink git commit: [FLINK-1307] Excluded directories that match the file-filter from recursive descent. - posted by fh...@apache.org on 2014/12/15 12:12:37 UTC, 0 replies.
- [2/2] incubator-flink git commit: [FLINK-1307] Allow file input from nested directory structure - posted by fh...@apache.org on 2014/12/15 12:12:38 UTC, 0 replies.
- incubator-flink git commit: Fixes broken code highlighting in documentation - posted by fh...@apache.org on 2014/12/15 14:55:20 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1327] [core] Fix wrapping of MemorySegments in ByteBuffers - posted by se...@apache.org on 2014/12/15 17:57:38 UTC, 0 replies.
- [1/2] incubator-flink git commit: [streaming] ReadTextFile re-implemented as RichFunction and cleanup - posted by mb...@apache.org on 2014/12/15 23:07:43 UTC, 0 replies.
- [2/2] incubator-flink git commit: [streaming] Basic support reading from local and distributed file systems in readTextFile methods - posted by mb...@apache.org on 2014/12/15 23:07:44 UTC, 0 replies.
- incubator-flink git commit: [Runtime] [Tests] Remove flaky check in LocalInstanceManagerTest - posted by uc...@apache.org on 2014/12/16 17:44:53 UTC, 0 replies.
- incubator-flink git commit: [Distributed runtime] Fail task if execution state update is unsuccessful - posted by uc...@apache.org on 2014/12/16 17:48:48 UTC, 0 replies.
- [1/5] incubator-flink git commit: [Java API] Fix equality checks on PojoTypeInfo - posted by se...@apache.org on 2014/12/16 22:24:05 UTC, 0 replies.
- [2/5] incubator-flink git commit: [APIs] Add ExecutionConfig - posted by se...@apache.org on 2014/12/16 22:24:06 UTC, 0 replies.
- [3/5] incubator-flink git commit: [FLINK-1325] [Java API] Add Java ClosureCleaner - posted by se...@apache.org on 2014/12/16 22:24:07 UTC, 0 replies.
- [4/5] incubator-flink git commit: [FLINK-1325] [Java API] Minor cleanups on the ClosureCleaner - posted by se...@apache.org on 2014/12/16 22:24:08 UTC, 0 replies.
- [5/5] incubator-flink git commit: Bump version to 0.9-incubating-SNAPSHOT - posted by se...@apache.org on 2014/12/16 22:24:09 UTC, 0 replies.
- Git Push Summary - posted by se...@apache.org on 2014/12/16 22:24:58 UTC, 0 replies.
- [1/2] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples - posted by mb...@apache.org on 2014/12/17 13:22:28 UTC, 0 replies.
- [2/2] incubator-flink git commit: [streaming] DataStream print functionality update - posted by mb...@apache.org on 2014/12/17 13:22:29 UTC, 0 replies.
- [1/5] incubator-flink git commit: [streaming] Updated deprecated iterative functionality and docs - posted by mb...@apache.org on 2014/12/17 21:38:03 UTC, 0 replies.
- [2/5] incubator-flink git commit: [FLINK-1325] [streaming] Added clousure cleaning to streaming - posted by mb...@apache.org on 2014/12/17 21:38:04 UTC, 0 replies.
- [3/5] incubator-flink git commit: Fix invalid type hierarchy creation by Pojo logic - posted by mb...@apache.org on 2014/12/17 21:38:05 UTC, 0 replies.
- [4/5] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer - posted by mb...@apache.org on 2014/12/17 21:38:06 UTC, 0 replies.
- [5/5] incubator-flink git commit: [FLINK-1333] Fixed getter/setter recognition for POJOs - posted by mb...@apache.org on 2014/12/17 21:38:07 UTC, 0 replies.
- [1/7] incubator-flink git commit: [streaming] Updated deprecated iterative functionality and docs - posted by mb...@apache.org on 2014/12/17 21:42:24 UTC, 0 replies.
- [2/7] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples - posted by mb...@apache.org on 2014/12/17 21:42:25 UTC, 0 replies.
- [3/7] incubator-flink git commit: [streaming] DataStream print functionality update - posted by mb...@apache.org on 2014/12/17 21:42:26 UTC, 0 replies.
- [4/7] incubator-flink git commit: Fix invalid type hierarchy creation by Pojo logic - posted by mb...@apache.org on 2014/12/17 21:42:27 UTC, 0 replies.
- [5/7] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer - posted by mb...@apache.org on 2014/12/17 21:42:28 UTC, 0 replies.
- [6/7] incubator-flink git commit: [FLINK-1333] Fixed getter/setter recognition for POJOs - posted by mb...@apache.org on 2014/12/17 21:42:29 UTC, 0 replies.
- [7/7] incubator-flink git commit: [FLINK-1325] [streaming] Added clousure cleaning to streaming - posted by mb...@apache.org on 2014/12/17 21:42:30 UTC, 0 replies.
- incubator-flink git commit: Fixes race condition in ExecutionGraph which allowed a job to go into the finished state without all job vertices having properly processed the finalizeOnMaster method. - posted by tr...@apache.org on 2014/12/18 11:45:46 UTC, 1 replies.
- incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method - posted by se...@apache.org on 2014/12/18 17:27:34 UTC, 0 replies.
- [01/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:44:57 UTC, 0 replies.
- [02/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:44:58 UTC, 0 replies.
- [03/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:44:59 UTC, 0 replies.
- [04/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:00 UTC, 0 replies.
- [05/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:01 UTC, 0 replies.
- [06/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:02 UTC, 0 replies.
- [07/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:03 UTC, 0 replies.
- [08/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:04 UTC, 0 replies.
- [09/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:05 UTC, 0 replies.
- [10/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:06 UTC, 0 replies.
- [11/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:07 UTC, 0 replies.
- [12/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:08 UTC, 0 replies.
- [13/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:09 UTC, 0 replies.
- [14/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:10 UTC, 0 replies.
- [15/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:11 UTC, 0 replies.
- [16/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:12 UTC, 0 replies.
- [17/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:13 UTC, 0 replies.
- [18/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:14 UTC, 0 replies.
- [19/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:15 UTC, 0 replies.
- [20/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:16 UTC, 0 replies.
- [21/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:17 UTC, 0 replies.
- [22/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:18 UTC, 0 replies.
- [23/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:19 UTC, 0 replies.
- [24/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:20 UTC, 0 replies.
- [25/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:21 UTC, 0 replies.
- [26/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:22 UTC, 0 replies.
- [27/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:23 UTC, 0 replies.
- [28/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:24 UTC, 0 replies.
- [29/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:25 UTC, 0 replies.
- [30/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:26 UTC, 0 replies.
- [31/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:27 UTC, 0 replies.
- [32/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:28 UTC, 0 replies.
- [33/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:29 UTC, 0 replies.
- [34/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:30 UTC, 0 replies.
- [35/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:31 UTC, 0 replies.
- [36/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:32 UTC, 0 replies.
- [37/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:33 UTC, 0 replies.
- [38/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:34 UTC, 0 replies.
- [39/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:35 UTC, 0 replies.
- [40/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:36 UTC, 0 replies.
- [41/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:37 UTC, 0 replies.
- [42/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:38 UTC, 0 replies.
- [43/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:39 UTC, 0 replies.
- [44/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:40 UTC, 0 replies.
- [45/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - posted by tr...@apache.org on 2014/12/18 19:45:41 UTC, 0 replies.
- [46/82] [abbrv] incubator-flink git commit: Updated DEPENDENCIES, NOTICE and LICENSE files. - posted by tr...@apache.org on 2014/12/18 19:45:42 UTC, 0 replies.
- [47/82] [abbrv] incubator-flink git commit: Adding timefactor to make up for slow travis tests. - posted by tr...@apache.org on 2014/12/18 19:45:43 UTC, 0 replies.
- [48/82] [abbrv] incubator-flink git commit: Removed blocking call in Execution.deploySlot - posted by tr...@apache.org on 2014/12/18 19:45:44 UTC, 0 replies.
- [49/82] [abbrv] incubator-flink git commit: Removed dead instance cleanup from InstanceManager so that Akka's watch mechanism is the current mean to detect dead instances. - posted by tr...@apache.org on 2014/12/18 19:45:45 UTC, 0 replies.
- [50/82] [abbrv] incubator-flink git commit: Made ExecutionGraph, Execution, ExecutionJobVertex, ExecutionVertex, AllocatedSlot, Instance, CoLocationConstraint, SharedSlot and SlotSharingGroupAssignment serializable. Integrated Kryo to be used to serializ - posted by tr...@apache.org on 2014/12/18 19:45:46 UTC, 0 replies.
- [51/82] [abbrv] incubator-flink git commit: Add debug guardians to suppress string generation which caused a significant performance loss. - posted by tr...@apache.org on 2014/12/18 19:45:47 UTC, 0 replies.
- [52/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:48 UTC, 0 replies.
- [53/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:49 UTC, 0 replies.
- [54/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:50 UTC, 0 replies.
- [55/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:51 UTC, 0 replies.
- [56/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:52 UTC, 0 replies.
- [57/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. - posted by tr...@apache.org on 2014/12/18 19:45:53 UTC, 0 replies.
- [58/82] [abbrv] incubator-flink git commit: Reworked local cluster start. TaskManager watches JobManager and tries reregistration in case of disconnect. Introduced akka.ask.timeout config parameter to configure akka timeouts. - posted by tr...@apache.org on 2014/12/18 19:45:54 UTC, 0 replies.
- [59/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. - posted by tr...@apache.org on 2014/12/18 19:45:55 UTC, 0 replies.
- [60/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. - posted by tr...@apache.org on 2014/12/18 19:45:56 UTC, 0 replies.
- [61/82] [abbrv] incubator-flink git commit: Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use ForkableFlinkMiniClus - posted by tr...@apache.org on 2014/12/18 19:45:57 UTC, 0 replies.
- [62/82] [abbrv] incubator-flink git commit: Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use ForkableFlinkMiniClus - posted by tr...@apache.org on 2014/12/18 19:45:58 UTC, 0 replies.
- [63/82] [abbrv] incubator-flink git commit: Add option to use single actor system for local execution. Use local connection manager if a single task manager is used for local execution. Remove synchronized blcok in getReceiverList of ChannelManager which - posted by tr...@apache.org on 2014/12/18 19:45:59 UTC, 0 replies.
- [64/82] [abbrv] incubator-flink git commit: Execute lookupConnectionInformation and UpdateTaskExecutionState concurrently within futures - posted by tr...@apache.org on 2014/12/18 19:46:00 UTC, 0 replies.
- [65/82] [abbrv] incubator-flink git commit: Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout. - posted by tr...@apache.org on 2014/12/18 19:46:01 UTC, 0 replies.
- [66/82] [abbrv] incubator-flink git commit: Exclude netty and protobuf dependency from hadoop-commons-2.0.0-alpha - posted by tr...@apache.org on 2014/12/18 19:46:02 UTC, 0 replies.
- [67/82] [abbrv] incubator-flink git commit: Use container based builds in travis. Enable caching for travis. Set travis fork count to 2. - posted by tr...@apache.org on 2014/12/18 19:46:03 UTC, 0 replies.
- [68/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:04 UTC, 0 replies.
- [69/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:05 UTC, 0 replies.
- [70/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:06 UTC, 0 replies.
- [71/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:07 UTC, 0 replies.
- [72/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:08 UTC, 0 replies.
- [73/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:09 UTC, 0 replies.
- [74/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:10 UTC, 0 replies.
- [75/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:11 UTC, 0 replies.
- [76/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - posted by tr...@apache.org on 2014/12/18 19:46:12 UTC, 0 replies.
- [77/82] [abbrv] incubator-flink git commit: Use Akka version 2.2.1 for hadoop version 2.0.0-alpha to resolve dependency conflicts. Adjust code to comply to respective Akka API. Remove obsolete TODO. - posted by tr...@apache.org on 2014/12/18 19:46:13 UTC, 0 replies.
- [78/82] [abbrv] incubator-flink git commit: Let the submitJobAndWait method check continuously whether the job manager is still alive. Terminate waiting for a response in case of a job manager outage. - posted by tr...@apache.org on 2014/12/18 19:46:14 UTC, 0 replies.
- [79/82] [abbrv] incubator-flink git commit: Exclude netty dependency from hadoop-mapreduce-client-core to resolve dependency conflict - posted by tr...@apache.org on 2014/12/18 19:46:15 UTC, 0 replies.
- [80/82] [abbrv] incubator-flink git commit: Add proper task resource removal in case that a task submission fails - posted by tr...@apache.org on 2014/12/18 19:46:16 UTC, 0 replies.
- [81/82] [abbrv] incubator-flink git commit: Fix race condition in ExecutionGraph which made the job finish before all vertices have called the finalizeOnMaster method. - posted by tr...@apache.org on 2014/12/18 19:46:17 UTC, 0 replies.
- [82/82] [abbrv] incubator-flink git commit: Remove experimental KryoSerialization for Akka - posted by tr...@apache.org on 2014/12/18 19:46:18 UTC, 0 replies.
- [1/6] incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method - posted by mb...@apache.org on 2014/12/18 19:59:52 UTC, 0 replies.
- [2/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - posted by mb...@apache.org on 2014/12/18 19:59:53 UTC, 0 replies.
- [3/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - posted by mb...@apache.org on 2014/12/18 19:59:54 UTC, 0 replies.
- [4/6] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory - posted by mb...@apache.org on 2014/12/18 19:59:55 UTC, 0 replies.
- [5/6] incubator-flink git commit: [streaming] Added immutability for window and filter operators - posted by mb...@apache.org on 2014/12/18 19:59:56 UTC, 0 replies.
- [6/6] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. - posted by mb...@apache.org on 2014/12/18 19:59:57 UTC, 0 replies.
- [1/5] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. - posted by mb...@apache.org on 2014/12/18 23:22:48 UTC, 0 replies.
- [2/5] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory - posted by mb...@apache.org on 2014/12/18 23:22:49 UTC, 0 replies.
- [3/5] incubator-flink git commit: [streaming] Added immutability for window and filter operators - posted by mb...@apache.org on 2014/12/18 23:22:50 UTC, 0 replies.
- [4/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - posted by mb...@apache.org on 2014/12/18 23:22:51 UTC, 0 replies.
- [5/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use - posted by mb...@apache.org on 2014/12/18 23:22:52 UTC, 0 replies.
- incubator-flink git commit: [streaming] Streaming local execution fix to create proper jobclient for minicluster - posted by mb...@apache.org on 2014/12/19 20:43:39 UTC, 0 replies.
- incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation - posted by mb...@apache.org on 2014/12/20 10:12:54 UTC, 1 replies.
- [1/2] incubator-flink git commit: [FLINK-1225] Fix for quickstart packaging - posted by mb...@apache.org on 2014/12/26 18:39:01 UTC, 0 replies.
- [2/2] incubator-flink git commit: [streaming] Temporal fix for streaming source parallelism - posted by mb...@apache.org on 2014/12/26 18:39:02 UTC, 0 replies.