| cf4c6e7 | Robert Metzger | 18 October 2014, 17:56:55 UTC | Commit for release 0.7.0-incubating | 18 October 2014, 17:56:55 UTC |
| 58943ad | Stephan Ewen | 18 October 2014, 01:08:39 UTC | [FLINK-1167] Handle unions at the root of the iteration This closes #160 | 18 October 2014, 17:46:29 UTC |
| 50f5ea8 | Stephan Ewen | 17 October 2014, 23:55:08 UTC | [FLINK-1164] Gracefully handle empty (identity) iterations | 18 October 2014, 17:46:29 UTC |
| ce2936a | Stephan Ewen | 17 October 2014, 14:46:45 UTC | [FLINK-1171] Move Scala API tests to flink-tests project This closes #159 | 18 October 2014, 17:32:50 UTC |
| 5b98ceb | Stephan Ewen | 14 October 2014, 19:08:28 UTC | Prevent RPC service from blocking on exceptions during task cleanup on canceling. | 18 October 2014, 17:32:50 UTC |
| 02b0f07 | Robert Metzger | 18 October 2014, 09:57:02 UTC | [FLINK-1170] address pull request review comments This closes #158 | 18 October 2014, 17:32:50 UTC |
| 578c373 | Robert Metzger | 17 October 2014, 08:58:15 UTC | [FLINK-1170] Fix faulty input split localization Pass hostname to split assigner Avoid clashes by only using the first component of the fully qualified hostname | 18 October 2014, 17:32:50 UTC |
| f396637 | Henry Saputra | 17 October 2014, 23:37:36 UTC | Fix the Javadoc link in DataStream class Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction and missing method reference in DataStream class. Author: Henry Saputra <henry.saputra@gmail.com> Closes #154 from hsaputra/fix_comments_streaming and squashes the following commits: 127e47a [Henry Saputra] Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction and missing method reference. | 18 October 2014, 17:32:50 UTC |
| dfe392b | szape | 09 October 2014, 09:50:01 UTC | [streaming] Added CoBatchedDataStream and CoWindowDataStream with reduce functionality + CoBatchReduce bugfix [streaming] RAT & Checkstyle fix | 17 October 2014, 15:13:41 UTC |
| b4230bc | szape | 08 October 2014, 10:35:39 UTC | [streaming] CoGroupedWindowReduceInvokable refactor [streaming] Grouped window reduce bugfix | 17 October 2014, 15:13:41 UTC |
| d7edaea | Aljoscha Krettek | 16 October 2014, 09:54:46 UTC | [scala] Change input of grouped ops from TraversableOnce to Iterator Iterator is a subclass of TraversableOnce, so it doesn't break existing code. We can have an Iterator anyways and it provides more functions for the user. | 17 October 2014, 14:49:44 UTC |
| 8d618be | Stephan Ewen | 14 October 2014, 16:02:04 UTC | Fix incorrect scheduler test that sometimes produces a deadlock | 17 October 2014, 14:48:55 UTC |
| c5e4b9a | Stephan Ewen | 14 October 2014, 15:21:10 UTC | Optimizer evaluates join hints from high level apis. | 17 October 2014, 14:48:55 UTC |
| bd88236 | Stephan Ewen | 14 October 2014, 13:52:54 UTC | JoinHints are passed to the optimizer | 17 October 2014, 14:48:55 UTC |
| c8d4e76 | Stephan Ewen | 14 October 2014, 13:52:34 UTC | Better test error messages when canceling tests fail | 17 October 2014, 14:48:55 UTC |
| 446a247 | Stephan Ewen | 13 October 2014, 18:07:59 UTC | [FLINK-1152] More robust resource release when tasks are canceled during deployment | 17 October 2014, 14:48:55 UTC |
| da54db6 | Stephan Ewen | 13 October 2014, 19:36:10 UTC | [FLINK-1148] Create a writeAsCsv(path, writemode) variant | 17 October 2014, 14:48:55 UTC |
| 9310703 | Stephan Ewen | 13 October 2014, 19:21:54 UTC | [FLINK-1143] Allow delta iterations that do not join with the solution set | 17 October 2014, 14:48:55 UTC |
| 1abadb1 | Stephan Ewen | 13 October 2014, 18:24:35 UTC | Fix various deprecation warnings in tests | 17 October 2014, 14:48:55 UTC |
| 460271c | Stephan Ewen | 14 October 2014, 12:37:42 UTC | Fix class loader when extracting lambdas | 17 October 2014, 14:48:55 UTC |
| 83cad28 | Till Rohrmann | 13 October 2014, 14:36:26 UTC | Set the cleanup timer thread of the BlobLibraryCacheManager to be a daemon. | 13 October 2014, 16:10:32 UTC |
| fd31185 | Robert Metzger | 12 October 2014, 08:32:48 UTC | Enable forgotten JoinITCase (for POJOs) for Scala and Java API | 13 October 2014, 16:10:32 UTC |
| aa62ad1 | Stephan Ewen | 13 October 2014, 14:37:52 UTC | Remove Guava dependecy from streaming-connectors (void shading otherwise) | 13 October 2014, 16:10:32 UTC |
| dddfb78 | Aljoscha Krettek | 13 October 2014, 13:53:11 UTC | Fix bug in Blob Manager, Cleanup Timer was not cancelled on Shutdown - | 13 October 2014, 16:10:32 UTC |
| f2ab125 | Aljoscha Krettek | 11 October 2014, 09:05:02 UTC | [doc] Update programming guide for scala expression keys | 13 October 2014, 16:10:32 UTC |
| da21ea3 | Aljoscha Krettek | 10 October 2014, 18:43:02 UTC | [doc] Fix javadoc building. The java8 Xdoclint:none fix was not correctly transferred when moving the javadoc building to a jekyll plugin. | 10 October 2014, 18:45:00 UTC |
| f605127 | Robert Metzger | 10 October 2014, 10:42:59 UTC | [YARN] Fix issue with port-offsetting. | 10 October 2014, 15:41:42 UTC |
| d749c24 | Aljoscha Krettek | 09 October 2014, 13:51:24 UTC | [scala] Add missing operator IT Cases | 09 October 2014, 16:35:22 UTC |
| f562d49 | Aljoscha Krettek | 08 October 2014, 15:45:30 UTC | Simplify Pojo/Tuple/CaseClass comparator extractKeys() method Also fixes a bug with Java/Scala interop: TupleTypeComparator was only checking for nested Java Tuples and Pojos, not Scala Case classes. | 09 October 2014, 16:35:22 UTC |
| 3eebaa8 | Fabian Hueske | 09 October 2014, 13:21:20 UTC | [FLINK-1150] Fix size estimate for FilterNode. Data size changes proportional to cardinality. This closes #146 | 09 October 2014, 15:20:30 UTC |
| 986f25f | Fabian Hueske | 09 October 2014, 12:03:48 UTC | [FLINK-1149] DataSource sets DOP to 1 for NonParallelInputs. | 09 October 2014, 14:44:30 UTC |
| 2de34f3 | Fabian Hueske | 09 October 2014, 14:00:03 UTC | Fixed missing logo in offline plan visualizer | 09 October 2014, 14:00:03 UTC |
| 22c370d | Robert Metzger | 09 October 2014, 09:45:52 UTC | [FLINK-1145] Fix incorrect getter / setter detection | 09 October 2014, 09:45:52 UTC |
| 758db36 | Fabian Hueske | 08 October 2014, 12:45:12 UTC | [FLINK-1136] Replaced Flink logo in web submission client Added Flink logo to JobManager web interface. Updated Run Example Quickstart screenshots Removed old gradients and unused image files from submission client. This closes #145. | 09 October 2014, 08:30:52 UTC |
| e2fd615 | Fabian Hueske | 07 October 2014, 12:46:36 UTC | [FLINK-1076] Extended Hadoop Compatibility documentation to cover Hadoop functions | 08 October 2014, 10:22:28 UTC |
| 3ebdebc | twalthr | 29 September 2014, 12:01:17 UTC | [FLINK-1107] Hadoop Compatibility Layer documented This closes #131 | 08 October 2014, 10:22:27 UTC |
| aa6d1cf | Fabian Hueske | 06 October 2014, 08:18:51 UTC | [FLINK-1076] Return type determined via type extraction. Added test cases. Minor improvements and clean-ups. | 08 October 2014, 10:22:27 UTC |
| 35415f2 | Artem Tsikiridis | 13 May 2014, 19:31:13 UTC | [FLINK-1076] Extend Hadoop compatibility. Added wrappers for stand-alone Map, Reduce, and CombinableReduce functions. | 08 October 2014, 10:22:27 UTC |
| 53d8f1f | Fabian Hueske | 08 October 2014, 10:21:27 UTC | Revert "Added wrappers for Hadoop functions" This reverts commit 74dded1c2cb87c459be3444d1c7387bbc510e154. | 08 October 2014, 10:21:27 UTC |
| 74dded1 | Fabian Hueske | 08 October 2014, 09:49:02 UTC | Added wrappers for Hadoop functions Tests and documentation included. Also tested on cluster. I hijacked @twalthr's PR #131 to build the documentation of the Hadoop function wrappers on top. Author: Fabian Hueske <fhueske@apache.org> Author: Artem Tsikiridis <artem.tsikiridis@cern.ch> Author: twalthr <info@twalthr.com> Closes #143 from fhueske/hadoopFunctions and squashes the following commits: f1b3f21 [Fabian Hueske] [FLINK-1076] Extended Hadoop Compatibility documentation to cover Hadoop functions f4be4a0 [twalthr] [FLINK-1107] Hadoop Compatibility Layer documented 4a62bdb [Fabian Hueske] [FLINK-1076] Return type determined via type extraction. Added test cases. Minor improvements and clean-ups. df947d9 [Artem Tsikiridis] [FLINK-1076] Extend Hadoop compatibility. Added wrappers for stand-alone Map, Reduce, and CombinableReduce functions. | 08 October 2014, 09:49:02 UTC |
| 6be8555 | Aljoscha Krettek | 07 October 2014, 10:00:15 UTC | Really add POJO support and nested keys for Scala API This also adds more integration tests, but not all tests of the Java API have been ported to Scala yet. | 08 October 2014, 09:39:01 UTC |
| 598ae37 | Robert Metzger | 07 October 2014, 13:44:38 UTC | Documentation and fixes | 08 October 2014, 09:39:01 UTC |
| fd0be2f | Robert Metzger | 06 October 2014, 15:11:37 UTC | Various fixes - improved error messages - the composite vs atomic bug aljoscha found - Comparator test for Pojo Comparator enabled - TODO removed - string-based key expression for group sorting fields definition - support for specifying "select all" using * and now also _ (for scala fans) - Exception if user is having multiple fields with the same name in the class | 08 October 2014, 09:39:01 UTC |
| 6b493fb | Robert Metzger | 06 October 2014, 09:45:24 UTC | Add Pojo support to Scala API | 08 October 2014, 09:39:01 UTC |
| aca6fbc | Robert Metzger | 05 October 2014, 17:30:18 UTC | Added expression keys to distinct and partition operator and addressed some of the comments | 08 October 2014, 09:39:01 UTC |
| 926f835 | Robert Metzger | 11 August 2014, 11:32:45 UTC | [FLINK-1032] Rework support for POJO types in the Java API | 08 October 2014, 09:39:01 UTC |
| ec82d97 | Gyula Fora | 07 October 2014, 21:08:39 UTC | [streaming] CoWindow operator rework + stream iteration example added | 07 October 2014, 22:38:09 UTC |
| 97a7322 | Tamas Ambrus | 01 October 2014, 14:26:05 UTC | [FLINK-1103] [streaming] Added Twitter streaming example and default inputs for examples | 07 October 2014, 22:37:02 UTC |
| 49812f3 | szape | 03 October 2014, 09:10:28 UTC | [streaming] Several bugfixes and doc updates | 07 October 2014, 22:31:32 UTC |
| 7af127e | Fabian Hueske | 01 October 2014, 12:41:29 UTC | Updated run-example quickstart (commands, screenshots) This closes #136 | 07 October 2014, 21:12:01 UTC |
| 6b6dae0 | Robert Metzger | 07 October 2014, 14:02:54 UTC | [FLINK-1106] Deprecate Record API | 07 October 2014, 14:02:54 UTC |
| ca4380c | Daniel Warneke | 24 September 2014, 13:00:58 UTC | Integration of new BLOB service. Looped through the user code class loader from the envrionment to the tasks. Added timed cleanup task to LibraryCacheManager to remove automatically unreferenced jar files. Moved registration logic out of the IOReadableWritable serialization logic. Updated logger. Made the LibraryCacheManager an object instead of a Singleton. Added proper shutdown of task manager and job manager. Removed nio import to support Java 6 compilation. Removed lock map from BlobLibraryCacheManager. Using global lock for synchronization. Marked StackOverflow code. Removed JavaDocs copyright message. Added getUserCodeClassLoader to AbstractInvokable class. This closes #126 and closes #107. | 06 October 2014, 14:20:11 UTC |
| 9caece6 | ghermann | 01 October 2014, 16:58:55 UTC | [streaming] Excluded unused recursively pulled dependencies Conflicts: flink-addons/flink-streaming/flink-streaming-connectors/pom.xml [streaming] Connectors POM formatting fix | 04 October 2014, 14:02:31 UTC |
| a0057f9 | Fabian Tschirschnitz | 01 October 2014, 14:46:54 UTC | [FLINK-1134] tried to fix issue with not terminating JVM when using RemoteCollectorOutputFormat This closes #138 | 03 October 2014, 14:43:18 UTC |
| 65bf092 | Stephan Ewen | 03 October 2014, 14:42:12 UTC | [FLINK-1110] Adjust collection based runtime and tests for classloaders in runtime context | 03 October 2014, 14:42:12 UTC |
| ff5ddd5 | Stephan Ewen | 01 October 2014, 23:54:26 UTC | [FLINK-1110] Fix HadoopInputFormat to work without prior serialization. | 03 October 2014, 14:22:34 UTC |
| 15f2544 | Stephan Ewen | 01 October 2014, 19:42:12 UTC | [FLINK-1110] Add iteration aggregators to collection based execution | 03 October 2014, 14:22:34 UTC |
| 3cc9a28 | Stephan Ewen | 01 October 2014, 18:11:52 UTC | [FLINK-1110] Fix mutable object safe mode for data sources in collection-based execution | 03 October 2014, 14:22:34 UTC |
| 54ede63 | Aljoscha Krettek | 01 October 2014, 15:43:38 UTC | [FLINK-1110] Fix Reduce and GroupReduce Test Failures | 03 October 2014, 14:22:34 UTC |
| cb19c74 | Ufuk Celebi | 01 October 2014, 09:26:40 UTC | [FLINK-1110] Fix IndexOutOfBoundsException in ListKeyGroupedIterator Occured when calling nextKey() and iterator not consumed with *last* key group. | 03 October 2014, 14:22:34 UTC |
| aea6a6d | Stephan Ewen | 30 September 2014, 21:14:53 UTC | [FLINK-1110] Adjust tests and fix various issues in the collection-based execution. | 03 October 2014, 14:22:34 UTC |
| ac69cb3 | Stephan Ewen | 30 September 2014, 19:32:54 UTC | [FLINK-1110] By default, collection-based execution behaves mutable-object safe. | 03 October 2014, 14:22:34 UTC |
| 3fd3110 | Aljoscha Krettek | 26 September 2014, 14:37:00 UTC | [FLINK-1110] Implement Collection-Based Execution for Delta Iterations | 03 October 2014, 14:22:34 UTC |
| b61f63c | Stephan Ewen | 23 September 2014, 21:47:59 UTC | [FLINK-1110] Adjusted test base to run programs both with local executor and collection executor | 03 October 2014, 14:22:34 UTC |
| 217b03e | Ufuk Celebi | 23 September 2014, 12:48:07 UTC | [FLINK-1110] Implement collection-based execution for coGroup | 03 October 2014, 14:22:34 UTC |
| d9ed4ad | Aljoscha Krettek | 23 September 2014, 13:16:33 UTC | [FLINK-1110] Add createCollectionEnvironment for Scala | 03 October 2014, 14:22:34 UTC |
| 471f340 | Till Rohrmann | 22 September 2014, 15:30:14 UTC | [FLINK-1110] Started implementing the JoinOperatorBase. Implemented JoinOperatorBase and test cases. | 03 October 2014, 14:22:33 UTC |
| 77ac6c0 | Stephan Ewen | 22 September 2014, 23:50:05 UTC | [FLINK-1110] Implement collection-based execution for bulk iterations | 03 October 2014, 14:22:33 UTC |
| 3eac6f2 | Stephan Ewen | 22 September 2014, 21:23:17 UTC | [FLINK-1110] Implement collection-based execution for mapPartition. Make groupReduce code compliant with pre-java-8 versions, fix java8 tests with moved type information classes. Fix Various warnings. | 03 October 2014, 14:22:33 UTC |
| fd3f5c2 | Aljoscha Krettek | 22 September 2014, 15:47:19 UTC | [FLINK-1110] Add Collection-Based execution for Reduce Operators Also fix some bugs resulting from moving stuff between packages | 03 October 2014, 14:22:33 UTC |
| 114af5a | Ufuk Celebi | 22 September 2014, 15:54:34 UTC | [FLINK-1110] Add execution on collections for flatMap | 03 October 2014, 14:22:33 UTC |
| fdad5bf | Stephan Ewen | 22 September 2014, 17:18:54 UTC | [FLINK-1110] Implement broadcast variables for collection-based execution | 03 October 2014, 14:22:33 UTC |
| 84bc21e | Stephan Ewen | 22 September 2014, 17:18:33 UTC | [FLINK-1110] Implement collection-based Cross | 03 October 2014, 14:22:33 UTC |
| bb71b23 | Stephan Ewen | 22 September 2014, 16:12:58 UTC | [FLINK-1110] Fix MapOperator execution and added simple test | 03 October 2014, 14:22:33 UTC |
| d10d59e | Stephan Ewen | 22 September 2014, 13:12:58 UTC | [FLINK-1110] Framework for collection-based execution | 03 October 2014, 14:22:33 UTC |
| 8e21204 | Stephan Ewen | 03 October 2014, 12:57:38 UTC | Add flag for unmanaged solution set to spargel | 03 October 2014, 12:57:38 UTC |
| 02314ad | Stephan Ewen | 26 September 2014, 15:05:50 UTC | [FLINK-12] Clean up configuration object - Remove class loader (was inconsistently used and set) - Objects are stored in their type, rather than as a string | 03 October 2014, 12:21:54 UTC |
| da3e507 | Stephan Ewen | 01 October 2014, 20:17:05 UTC | Add an object-based variant of the solution set | 03 October 2014, 11:42:05 UTC |
| b689f3f | Aljoscha Krettek | 02 October 2014, 06:55:30 UTC | Move DeltaIteration Sanity Check to Base Operators Is now in JoinOperator and CoGroupOperator. We don't need the special Scala API sanity check anymore now since they use java operators that now correctly check in the base class. | 02 October 2014, 06:56:16 UTC |
| 02c0845 | twalthr | 01 October 2014, 15:25:36 UTC | [FLINK-1133] TypeExtractor now also supports nested Tuple-input derivation This closes #137 | 01 October 2014, 19:44:51 UTC |
| 27e4020 | twalthr | 01 October 2014, 14:40:42 UTC | [FLINK-1133] TypeExtractor resolves also variables inside Tuple-input | 01 October 2014, 19:44:38 UTC |
| d5fb423 | Stephan Ewen | 01 October 2014, 17:31:38 UTC | Guava shading fixes for eclipse and IntelliJ | 01 October 2014, 17:31:38 UTC |
| 1c2ce3a | Stephan Ewen | 01 October 2014, 16:35:29 UTC | Repair guava dependencies | 01 October 2014, 16:35:29 UTC |
| 425e8a4 | Ufuk Celebi | 01 October 2014, 16:07:22 UTC | [FLINK-1124] Remove redundant HTML close tag | 01 October 2014, 16:09:08 UTC |
| 73c6fec | Gyula Fora | 01 October 2014, 07:32:56 UTC | Guava shading issue fix for Eclipse | 01 October 2014, 15:11:38 UTC |
| 9e722df | szape | 30 September 2014, 18:20:18 UTC | [streaming] Improved tests for CoReduceInvokables | 01 October 2014, 15:11:38 UTC |
| 127470b | Gyula Fora | 30 September 2014, 15:59:39 UTC | [streaming] ConnectedDataStream API and operator cleanup + modified windowReduceGroup functionality | 01 October 2014, 15:11:38 UTC |
| 6492af0 | Gyula Fora | 29 September 2014, 20:18:36 UTC | [streaming] Reduce and GroupReduce invokable refactor and performance tweak | 01 October 2014, 15:11:38 UTC |
| 618effa | szape | 28 September 2014, 20:21:33 UTC | [streaming] Added CoBatchReduceInvokable, CoWindowReduceInvokable, CoGroupedBatchReduceInvokable, CoGroupedWindowReduceInvokable | 01 October 2014, 15:11:38 UTC |
| 39ac5ab | Stephan Ewen | 01 October 2014, 11:27:25 UTC | [FLINK-514] Fix additional javadoc problems and add suppressions for certain compiler warnings. | 01 October 2014, 12:30:14 UTC |
| c8054a3 | Daniel Warneke | 01 October 2014, 10:25:38 UTC | [FLINK-514] Fixed javadoc problems | 01 October 2014, 12:03:00 UTC |
| 949699d | Stephan Ewen | 01 October 2014, 10:14:18 UTC | Fix guava dependency in flink-streaming-core to allow IDE local testing. | 01 October 2014, 12:03:00 UTC |
| 8573bf4 | Aljoscha Krettek | 01 October 2014, 11:11:59 UTC | [scala] Simplify Operation Classes: No more Impl Classes | 01 October 2014, 11:13:09 UTC |
| 15e5990 | Stephan Ewen | 30 September 2014, 12:36:09 UTC | [FLINK-1118] Exclude log (and crash) files from rat checks. | 30 September 2014, 16:39:59 UTC |
| 719e288 | Stephan Ewen | 30 September 2014, 12:16:16 UTC | - Allow dependencies to retain guava - Clean dependencies in flink-streaming connectors | 30 September 2014, 16:39:59 UTC |
| 626d6b7 | Stephan Ewen | 30 September 2014, 12:15:22 UTC | [FLINK-1117] Clean up flink-avro project: remove deprecated AvroRecord format, migrate tests to new java api. | 30 September 2014, 16:39:58 UTC |
| 38e4755 | Stephan Ewen | 29 September 2014, 20:27:35 UTC | Deactivate shade plugin for quickstart projects | 30 September 2014, 16:39:58 UTC |
| 758de7d | Stephan Ewen | 29 September 2014, 18:39:09 UTC | Major depedendency cleanups - add "flink-shading" for shaded libraries (currently guava only) - relocate guava in all projects and exclude it from the lib and exported dependencies - Exlude unnecessary transitive dependencies from hadoop 1 | 30 September 2014, 16:39:58 UTC |
| 7e43b1c | Robert Metzger | 28 September 2014, 18:54:23 UTC | add shading for guava | 30 September 2014, 16:39:58 UTC |
| 30e84ff | Robert Metzger | 28 September 2014, 18:10:07 UTC | [FLINK-1072] improved build matrix | 30 September 2014, 16:39:58 UTC |
