commits  

Messages by Date

• 2014/12/18 [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. trohrmann
• 2014/12/18 [59/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. trohrmann
• 2014/12/18 [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 trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [66/82] [abbrv] incubator-flink git commit: Exclude netty and protobuf dependency from hadoop-commons-2.0.0-alpha trohrmann
• 2014/12/18 [69/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
• 2014/12/18 [64/82] [abbrv] incubator-flink git commit: Execute lookupConnectionInformation and UpdateTaskExecutionState concurrently within futures trohrmann
• 2014/12/18 [73/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [56/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [67/82] [abbrv] incubator-flink git commit: Use container based builds in travis. Enable caching for travis. Set travis fork count to 2. trohrmann
• 2014/12/18 [48/82] [abbrv] incubator-flink git commit: Removed blocking call in Execution.deploySlot trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [65/82] [abbrv] incubator-flink git commit: Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 [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. trohrmann
• 2014/12/18 incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method sewen
• 2014/12/18 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. trohrmann
• 2014/12/18 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. trohrmann
• 2014/12/17 [1/7] incubator-flink git commit: [streaming] Updated deprecated iterative functionality and docs mbalassi
• 2014/12/17 [2/7] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples mbalassi
• 2014/12/17 [4/7] incubator-flink git commit: Fix invalid type hierarchy creation by Pojo logic mbalassi
• 2014/12/17 [5/7] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer mbalassi
• 2014/12/17 [3/7] incubator-flink git commit: [streaming] DataStream print functionality update mbalassi
• 2014/12/17 [7/7] incubator-flink git commit: [FLINK-1325] [streaming] Added clousure cleaning to streaming mbalassi
• 2014/12/17 [6/7] incubator-flink git commit: [FLINK-1333] Fixed getter/setter recognition for POJOs mbalassi
• 2014/12/17 [2/5] incubator-flink git commit: [FLINK-1325] [streaming] Added clousure cleaning to streaming mbalassi
• 2014/12/17 [5/5] incubator-flink git commit: [FLINK-1333] Fixed getter/setter recognition for POJOs mbalassi
• 2014/12/17 [4/5] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer mbalassi
• 2014/12/17 [1/5] incubator-flink git commit: [streaming] Updated deprecated iterative functionality and docs mbalassi
• 2014/12/17 [3/5] incubator-flink git commit: Fix invalid type hierarchy creation by Pojo logic mbalassi
• 2014/12/17 [1/2] incubator-flink git commit: [streaming] [examples] Refactor and packaging for windowing examples mbalassi
• 2014/12/17 [2/2] incubator-flink git commit: [streaming] DataStream print functionality update mbalassi
• 2014/12/16 Git Push Summary sewen
• 2014/12/16 [5/5] incubator-flink git commit: Bump version to 0.9-incubating-SNAPSHOT sewen
• 2014/12/16 [3/5] incubator-flink git commit: [FLINK-1325] [Java API] Add Java ClosureCleaner sewen
• 2014/12/16 [4/5] incubator-flink git commit: [FLINK-1325] [Java API] Minor cleanups on the ClosureCleaner sewen
• 2014/12/16 [2/5] incubator-flink git commit: [APIs] Add ExecutionConfig sewen
• 2014/12/16 [1/5] incubator-flink git commit: [Java API] Fix equality checks on PojoTypeInfo sewen
• 2014/12/16 incubator-flink git commit: [Distributed runtime] Fail task if execution state update is unsuccessful uce
• 2014/12/16 incubator-flink git commit: [Runtime] [Tests] Remove flaky check in LocalInstanceManagerTest uce
• 2014/12/15 [1/2] incubator-flink git commit: [streaming] ReadTextFile re-implemented as RichFunction and cleanup mbalassi
• 2014/12/15 [2/2] incubator-flink git commit: [streaming] Basic support reading from local and distributed file systems in readTextFile methods mbalassi
• 2014/12/15 incubator-flink git commit: [FLINK-1327] [core] Fix wrapping of MemorySegments in ByteBuffers sewen
• 2014/12/15 incubator-flink git commit: Fixes broken code highlighting in documentation fhueske
• 2014/12/15 [2/2] incubator-flink git commit: [FLINK-1307] Allow file input from nested directory structure fhueske
• 2014/12/15 [1/2] incubator-flink git commit: [FLINK-1307] Excluded directories that match the file-filter from recursive descent. fhueske
• 2014/12/14 [3/4] incubator-flink git commit: [misc] Fix/suppress various compiler warnings. sewen
• 2014/12/14 [2/4] incubator-flink git commit: [scala] Change ScalaAggregateOperator to use TypeSerializer sewen
• 2014/12/14 [4/4] incubator-flink git commit: [FLINK-1305] [FLINK-1304] Test for HadoopInputWrapper and NullWritable support sewen
• 2014/12/14 [1/4] incubator-flink git commit: [FLINK-1322] Make Scala API respect WriteMode set in Config sewen
• 2014/12/14 incubator-flink git commit: [FLINK-1324] [runtime] Trailing data is cached before the local input strategies are closed. sewen
• 2014/12/12 incubator-flink git commit: [FLINK-1208] Enable CsvInputFormats to ignore invalid lines and lines starting with comments fhueske
• 2014/12/12 incubator-flink git commit: [FLINK-1287] LocalizableSplitAssigner prefers splits with less degrees of freedom fhueske
• 2014/12/12 incubator-flink git commit: Exclude docs/_site/** from License Check aljoscha
• 2014/12/12 incubator-flink git commit: [FLINK-998] Close TCP connections after destroying logical channels uce
• 2014/12/12 incubator-flink git commit: [FLINK-1302] Make JDBCInputFormat implement the NonParallelInput interface rmetzger
• 2014/12/12 incubator-flink git commit: Enable flink-hbase module for hadoop1 build as well. rmetzger
• 2014/12/11 incubator-flink git commit: [FLINK-1310] Change ClosureCleaner Logging to DEBUG uce
• 2014/12/11 incubator-flink git commit: [scala] Add withParameters() support for sinks/sources uce
• 2014/12/10 incubator-flink git commit: Fixed java quickstart example rmetzger
• 2014/12/10 svn commit: r1644497 - /incubator/flink/index.html ktzoumas
• 2014/12/10 [2/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional fhueske
• 2014/12/10 [5/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional fhueske
• 2014/12/10 [6/6] incubator-flink git commit: [FLINK-1040] Updated JavaDocs and removed deprecated types() calls from examples and tests fhueske
• 2014/12/10 [3/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional fhueske
• 2014/12/10 [4/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional fhueske
• 2014/12/10 [1/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional fhueske
• 2014/12/10 [2/4] incubator-flink git commit: [FLINK-1315] [optimizer] Fix bug in branch tracking logic. sewen
• 2014/12/10 [4/4] incubator-flink git commit: [java8] Fix pom.xml to properly work with Eclipse m2e sewen
• 2014/12/10 [1/4] incubator-flink git commit: [FLINK-1316] [web client] Fix plan display for nodes referenced from multiple closures. sewen
• 2014/12/10 [3/4] incubator-flink git commit: [FLINK-1315] [optimizer] Extra test reproducing the IllegalStateException bug in bulk iterations. sewen
• 2014/12/10 [1/5] incubator-flink git commit: Updated java 8 package to match flink-examples standards mbalassi
• 2014/12/10 [3/5] incubator-flink git commit: [streaming] Java 8 WordCount example added for streaming mbalassi
• 2014/12/10 [5/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas mbalassi
• 2014/12/10 [4/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas mbalassi
• 2014/12/10 [2/5] incubator-flink git commit: [FLINK-1312] [streaming] OutputSelector changed to SAM-type to allow java 8 lambdas for splitting mbalassi
• 2014/12/09 incubator-flink git commit: [FLINK-1311] [optimizer] Correctly tag static/dynamic path for auxiliary nodes in iterations. sewen
• 2014/12/08 svn commit: r1643802 - /incubator/flink/site/downloads.html rmetzger
• 2014/12/08 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 ktzoumas
• 2014/12/08 incubator-flink git commit: [FLINK-1139] Updated Hadoop Compatibility documentation fhueske
• 2014/12/08 [2/2] incubator-flink git commit: [FLINK-1139] Fixed HadoopOutputFormat to run with DOP > 1 fhueske
• 2014/12/08 [1/2] incubator-flink git commit: [FLINK-1139] Added FinalizeOnMaster hook to run code after the last task of an OutputFormat completed fhueske
• 2014/12/06 svn commit: r1643518 - in /incubator/flink: index.html site/downloads.html site/index.html rmetzger
• 2014/12/05 [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. fhueske
• 2014/12/05 [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. fhueske
• 2014/12/05 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... ktzoumas
• 2014/12/05 svn commit: r1643435 - /incubator/flink/index.html ktzoumas
• 2014/12/05 incubator-flink git commit: [scala] Fix TupleSerializerTest for corrected CaseClassSerializer aljoscha
• 2014/12/05 incubator-flink git commit: [scala] Fix non-reuse copy in CaseClassSerializer aljoscha
• 2014/12/05 [28/34] incubator-flink git commit: [FLINK-1279] [streaming] Forward partitioning changed to use round-robin method mbalassi
• 2014/12/05 [17/34] incubator-flink git commit: [streaming] Windowing API update + package refactor mbalassi
• 2014/12/05 [29/34] incubator-flink git commit: [streaming] Renamed test cases for window and grouped window invokable to be consistent with the invokable names mbalassi
• 2014/12/05 [19/34] incubator-flink git commit: [streaming] Extractor requirement removed for custom timestamp windowing mbalassi
• 2014/12/05 [12/34] incubator-flink git commit: [streaming] Adding unit tests for the grouped windowing invokable. mbalassi
• 2014/12/05 [09/34] incubator-flink git commit: [streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases. mbalassi
• 2014/12/05 [08/34] incubator-flink git commit: [streaming] Added extractor implementations for various extractions and conversions. (incl. test cases) mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [15/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [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 mbalassi
• 2014/12/05 [06/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases. mbalassi
• 2014/12/05 [32/34] incubator-flink git commit: [streaming] Changed GroupedWindowInvokable to always delete groups in case they have an empty element buffer mbalassi
• 2014/12/05 [34/34] incubator-flink git commit: [docs] [streaming] Windowing rework documentation update mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [31/34] incubator-flink git commit: [streaming] Introduced central eviction policies in the grouped window invokable mbalassi
• 2014/12/05 [14/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [21/34] incubator-flink git commit: [streaming] Window cross API rework mbalassi
• 2014/12/05 [23/34] incubator-flink git commit: [streaming] Windowing helper API cleanup mbalassi
• 2014/12/05 [10/34] incubator-flink git commit: [streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions. mbalassi
• 2014/12/05 [03/34] incubator-flink git commit: [streaming] Introduced extractor interface to enable flexible handling of arbitrary input data types. mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [30/34] incubator-flink git commit: [streaming] Central trigger/eviction API integration + invokable refactor mbalassi
• 2014/12/05 [22/34] incubator-flink git commit: [streaming] Window join api rework to support functional style mbalassi
• 2014/12/05 [20/34] incubator-flink git commit: [streaming] Added test cases for the policy based windowing invokable. mbalassi
• 2014/12/05 [07/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on data punctuation. (incl. test cases) mbalassi
• 2014/12/05 [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. mbalassi
• 2014/12/05 [26/34] incubator-flink git commit: [streaming] Created several examples for the usage of policy based windowing. mbalassi
• 2014/12/05 [16/34] incubator-flink git commit: [streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper. mbalassi
• 2014/12/05 [25/34] incubator-flink git commit: [streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies mbalassi
• 2014/12/05 [33/34] incubator-flink git commit: [streaming] Updated javadocs for new windowing semantics mbalassi
• 2014/12/05 [18/34] incubator-flink git commit: [streaming] Windowing API update + package refactor mbalassi
• 2014/12/05 [13/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes mbalassi
• 2014/12/04 incubator-flink git commit: [FLINK-1157] Document TaskManager slots and minor fixes. rmetzger
• 2014/12/01 incubator-flink git commit: [Java API] [docs] Rephrase Javadoc of minBy/maxBy and link from min/max uce
• 2014/12/01 incubator-flink git commit: [FLINK-1292] Allow for longer normalized keys when using composite keys sewen
• 2014/12/01 incubator-flink git commit: [Docs] Fix rendering issue and typo rmetzger
• 2014/12/01 incubator-flink git commit: [FLINK-984] Compiler tests for distinct(). Adopted the old code from @markus-h rmetzger
• 2014/11/29 incubator-flink git commit: [FLINK-1154] Quickfix to kill TaskManagers in YARN mode. rmetzger
• 2014/11/28 incubator-flink git commit: [FLINK-1291] Remove default GC options from the shell scripts uce
• 2014/11/28 incubator-flink git commit: [Docs] Just a typo in docs/index.md rmetzger
• 2014/11/27 incubator-flink git commit: [scala] [runtime] Add extra tests for sorting of case classes sewen
• 2014/11/27 [2/5] incubator-flink git commit: [FLINK-1270] [APIs] FS.get() supports relative paths sewen
• 2014/11/27 [3/5] incubator-flink git commit: [FLINK-1273] [runtime] Add Void type to basic types sewen
• 2014/11/27 [1/5] incubator-flink git commit: [FLINK-1095] [clients] Remove '-d' option in info from CliFrontend sewen
• 2014/11/27 [4/5] incubator-flink git commit: Upgraded HBase addon to HBase 0.98.x and new Tuple APIs sewen
• 2014/11/27 [5/5] incubator-flink git commit: [FLINK-1290] Fix Optimizer to create plans when encountering incompatible partitionings. sewen
• 2014/11/27 incubator-flink git commit: Removed TypeSerializerFactory from ScalaCsvInputFormat. The TypeSerializer is now serialized directly. trohrmann
• 2014/11/27 [1/3] incubator-flink git commit: [scala] Add equals() to TraversableTypeInfo aljoscha
• 2014/11/27 [2/3] incubator-flink git commit: Rewrite TPC-H Q3 to use Long instead of Integer aljoscha
• 2014/11/27 [3/3] incubator-flink git commit: [scala] Fix slow building of adjacency list in Scala PageRank aljoscha
• 2014/11/27 incubator-flink git commit: [runtime] CaseClassSerializer correctly treated as stateful sewen
• 2014/11/27 [3/4] incubator-flink git commit: [FLINK-1282] [docs] Update layout of docs uce
• 2014/11/27 [1/4] incubator-flink git commit: [FLINK-1282] [docs] Make Flink logo link back to frontpage uce
• 2014/11/27 [2/4] incubator-flink git commit: [FLINK-1282] [docs] Added {{ site.baseurl }} to css and image paths uce
• 2014/11/27 [4/4] incubator-flink git commit: [docs] Fix paths to work with local builds uce
• 2014/11/27 incubator-flink git commit: [docs] Fix paths to work with local builds uce
• 2014/11/27 incubator-flink git commit: [scala] Add ClosureCleaner for Scala Lambdas aljoscha
• 2014/11/26 incubator-flink git commit: [FLINK-1234] Activate hadoop2 profile by default rmetzger
• 2014/11/26 [2/2] incubator-flink git commit: [FLINK-1282] [docs] Make Flink logo link back to frontpage uce
• 2014/11/26 [1/2] incubator-flink git commit: [FLINK-1282] [docs] Added {{ site.baseurl }} to css and image paths uce
• 2014/11/26 [3/3] incubator-flink git commit: [Scala API] Case Class serializer can work with classes that cannot be instantiated empty sewen
• 2014/11/26 [1/3] incubator-flink git commit: [FLINK-1286] [APIs] [runtime] Fix serialization in CollectionInputFormat and generate meaningful error messages sewen
• 2014/11/26 [2/3] incubator-flink git commit: [FLINK-1278] [runtime] (part 1) Remove special code paths for the Record data type in the input readers and the source task. sewen
• 2014/11/26 incubator-flink git commit: [FLINK-1282] [docs] Update layout of docs uce
• 2014/11/26 [2/3] incubator-flink git commit: [FLINK-658] [APIs] Add group sorting to CoGroup sewen
• 2014/11/26 [3/3] incubator-flink git commit: [runtime] Quick fix for error with unsupported ship strategy sewen
• 2014/11/26 [1/3] incubator-flink git commit: [Java API] Fix various warnings sewen
• 2014/11/25 incubator-flink git commit: Small changes and tests for the newly introduced EnumType uce
• 2014/11/25 [1/2] incubator-flink git commit: [FLINK-1221] Use only method name and location as default operator names uce
• 2014/11/25 [2/2] incubator-flink git commit: [FLINK-1221] Use StackTraceElement methods instead of String parsing uce
• 2014/11/25 incubator-flink git commit: [FLINK-1249] [APIs] [compiler] Add custom partitioner for CoGroup trohrmann
• 2014/11/25 incubator-flink git commit: Fixes FLINK-1276 aljoscha
• 2014/11/24 [1/2] incubator-flink git commit: [FLINK-1173] [streaming] Add socket text stream as a data source for the streaming API mbalassi
• 2014/11/24 [2/2] incubator-flink git commit: [FLINK-1173] [streaming] SocketTextStream minor fixes + documentation mbalassi
• 2014/11/22 incubator-flink git commit: Minor code cleanups - left from previous patches sewen
• 2014/11/21 [2/2] incubator-flink git commit: [FLINK-1263] [optimizer] Implement compatibility checks for binary operators and custom partitioning sewen
• 2014/11/21 [1/2] incubator-flink git commit: [APIs] Enhance test coverage for CollectionInputFormat and add tests for failed serializations of user code objects sewen
• 2014/11/21 incubator-flink git commit: Log memory usage stats at INFO level instead of DEBUG uce
• 2014/11/21 incubator-flink git commit: Removed object reusage in GenericArraySerializer's deserialize method. trohrmann
• 2014/11/20 [1/2] incubator-flink git commit: [FLINK-820] [compiler] Support for disconnected data flows sewen
• 2014/11/20 [2/2] incubator-flink git commit: [FLINK-1264] [compiler] Properly forward custom partitioners to the runtime sewen
• 2014/11/20 incubator-flink git commit: [Flink-1262] inconsistency between CsvReader.java and TupleGenerator.java rmetzger
• 2014/11/20 incubator-flink git commit: [FLINK-1265] Fix user classloader bug for registerInputOutput() method fhueske
• 2014/11/20 incubator-flink git commit: Added binary input and output format which uses the objects' TypeSerializer to serialize them. trohrmann
• 2014/11/20 [2/3] incubator-flink git commit: [FLINK-1251] Enums are now handled properly by the collection input format rmetzger
• 2014/11/20 [3/3] incubator-flink git commit: [FLINK-1252] Add support for serializing Date and Enums in the Java API rmetzger
• 2014/11/20 [1/3] incubator-flink git commit: [FLINK-1252] address pull request comments rmetzger
• 2014/11/20 incubator-flink git commit: Minor code clean up uce
• 2014/11/20 incubator-flink git commit: [FLINK-1142] Log information about I/O manager temp dirs uce
• 2014/11/19 [2/2] incubator-flink git commit: [streaming] Source parallelism API update mbalassi
• 2014/11/19 [1/2] incubator-flink git commit: [streaming] Fixed async buffer sending at end of AbstractInvokable mbalassi
• 2014/11/19 [1/2] incubator-flink git commit: [FLINK-933] Add primitive input format to read a sequence of primitives fhueske
• 2014/11/19 [2/2] incubator-flink git commit: [FLINK-993] Primitive input format fails for invalid input. Adapted documentation. fhueske
• 2014/11/19 [1/2] incubator-flink git commit: [FLINK-1253] [tests] Make sure tests do not die with garbage collection overhead exceeded sewen
• 2014/11/19 [2/2] incubator-flink git commit: [FLINK-1254] [compiler] Fix compiler bug for pipeline breaker placement sewen
• 2014/11/19 incubator-flink git commit: Added getExecutionEnvironment to the DataSet of the Scala API. trohrmann
• 2014/11/19 svn commit: r1640540 - in /incubator/flink/site/docs: 0.6-incubating/ 0.6-incubating/api/java/ 0.6-incubating/api/java/org/apache/flink/api/avro/ 0.6-incubating/api/java/org/apache/flink/api/avro/class-use/ 0.6-incubating/api/java/org/apache/flink/api/... uce
• 2014/11/19 incubator-flink git commit: Add byte array serialization to InstantiationUtil uce
• 2014/11/19 incubator-flink git commit: Minor code clean up to get rid of IntelliJ IDEA warnings uce
• 2014/11/19 incubator-flink git commit: [FLINK-1247] [docs] Fix broken links in documentation uce
• 2014/11/19 incubator-flink git commit: [FLINK-1247] [docs] Fix broken links in documentation uce
• 2014/11/18 [2/2] incubator-flink git commit: [FLINK-1250] [config] [docs] Correct and document config keys for heartbeat intervals and timeouts sewen

• Earlier messages
• Later messages