| 26bc321 | Stephan Ewen | 09 July 2014, 09:23:18 UTC | Fix optimizer error in channel instantiation (wrong parameterization) | 09 July 2014, 09:23:18 UTC |
| 49ca3ed | Stephan Ewen | 09 July 2014, 01:20:30 UTC | Clean up checkstyle and JavaDoc errors in core project | 09 July 2014, 01:20:30 UTC |
| 52f9cf6 | Stephan Ewen | 09 July 2014, 01:10:45 UTC | No explicit caching when hash table is cached Add tests for explicit cache removal when hash table is cached | 09 July 2014, 01:19:24 UTC |
| a9b1daa | Stephan Ewen | 09 July 2014, 01:07:21 UTC | Fix missing strategy constants in JSON dump generator | 09 July 2014, 01:10:18 UTC |
| 03c6160 | Stephan Ewen | 09 July 2014, 01:03:21 UTC | Fix cost formulas for cached hash joins Fix estimation bug in channels Add tests for isolated cost formulas Add tests for channel class in plan candidates | 09 July 2014, 01:09:48 UTC |
| ce65fb6 | Stephan Ewen | 08 July 2014, 15:24:43 UTC | Add dedicated test for the type extraction on input formats. Fix various JavaDoc errors. | 09 July 2014, 01:09:36 UTC |
| 5cec8e8 | twalthr | 30 June 2014, 10:02:37 UTC | [FLINK-701] Rework of TypeExtractor for SAM support This closes #52 | 08 July 2014, 14:55:13 UTC |
| 8ea6536 | Stephan Ewen | 08 July 2014, 14:46:47 UTC | Clean up exception logging in JobManagerITCase. | 08 July 2014, 14:55:13 UTC |
| 53c7a89 | Stephan Ewen | 08 July 2014, 14:15:23 UTC | Fix various JavaDoc errors | 08 July 2014, 14:55:07 UTC |
| 47a68ad | Markus Holzemer | 16 June 2014, 07:41:46 UTC | [FLINK-836] Rework of the cached match driver | 08 July 2014, 14:54:15 UTC |
| 99c888c | Markus Holzemer | 20 May 2014, 08:00:40 UTC | [FLINK-795] Tests for the integration of the cached match driver into the optimizer | 08 July 2014, 14:54:01 UTC |
| 48a703f | Markus Holzemer | 19 May 2014, 08:54:34 UTC | [FLINK-836] Integration of the CachedBuildSideMatchDriver into the optimizer | 08 July 2014, 12:36:02 UTC |
| 7b6295d | Till Rohrmann | 07 July 2014, 14:20:07 UTC | [FLINK-994] Added test cases for AbstractPagedInputView, fixed problem with hbase. This closes #53 | 08 July 2014, 10:37:41 UTC |
| 98e659e | Till Rohrmann | 29 June 2014, 17:08:31 UTC | [FLINK-994] Replaced DataInput and DataOutput with DataInputView and DataOutputView | 08 July 2014, 10:37:24 UTC |
| 3f51195 | Henry Saputra | 08 July 2014, 07:38:46 UTC | First cleanup attempt, mostly on Scala code, to follow guidelines from http://docs.scala-lang.org/style: 1. Remove return statement from Scala code where it is not necessary (end of method definition) 2. Remove extra ; from Scala and Java code 3. First drop to abide to 100 chars per line for Scala code. Will send another PR for other files as I have encountered. 4. Remove parentheses for empty argument methods that do not have side effect (see http://www.artima.com/pins1ed/composition-and-inheritance.html#i1343251059-1) 5. Remove unused import statements in Scala code as I have encountered them. This is first drop to refactor and clean up Scala code to see comment/ response from community. More PRs for follow up code will come. Close #64 | 08 July 2014, 10:11:25 UTC |
| 5928706 | sebastian kunert | 03 July 2014, 11:52:13 UTC | [documentation] fixed a lot of links, better gh_link plugin This closes #54 | 04 July 2014, 09:54:37 UTC |
| 88e4dac | Robert Metzger | 02 July 2014, 12:43:35 UTC | [documentation] fix internals linking | 04 July 2014, 09:22:17 UTC |
| b945916 | Sebastian Kunert | 01 July 2014, 13:30:41 UTC | [documentation] modified gh_link to support naming | 04 July 2014, 09:22:11 UTC |
| b422fe2 | Till Rohrmann | 30 June 2014, 09:45:49 UTC | [FLINK-990] Added constant fields and combinable annotations forwarding to Scala API This closes #51 | 03 July 2014, 13:04:56 UTC |
| 32a003d | Till Rohrmann | 02 July 2014, 14:00:55 UTC | [FLINK-996] Fix for bug in union replacement This closes #56 | 03 July 2014, 12:49:39 UTC |
| cf29798 | Stephan Ewen | 03 July 2014, 11:33:53 UTC | Fix various error messages and invalid JavaDocs. | 03 July 2014, 12:49:39 UTC |
| 883474d | sebastian kunert | 19 June 2014, 14:17:59 UTC | [FLINK-932] Introduce automatic generation of semantic props for projections This closes #29 | 03 July 2014, 12:49:39 UTC |
| 8a8060e | Markus Holzemer | 03 July 2014, 10:34:52 UTC | [FLINK-893] Inconsistent Iteration Step Function gives nonesense error message I adjusted the error message. Author: Markus Holzemer <markus.holzemer@gmx.de> Closes #50 from markus-h/iteration_translation_exception and squashes the following commits: 34a6f87 [Markus Holzemer] adjusted error message when encountering a translation failure for iterations | 03 July 2014, 10:34:52 UTC |
| 3c8bdee | TobiasWiens | 23 June 2014, 07:56:44 UTC | [FLINK-888] Add swap() to Tuple2 | 03 July 2014, 10:29:47 UTC |
| 7a4c209 | Jonathan | 03 July 2014, 10:07:25 UTC | Finished Flink-928 Taskmanagers are now displayed in the web interface @rmetzger Author: Jonathan <Jonathan@Hasenburg.de> Closes #43 from JonathanH5/webclient and squashes the following commits: 5cc5f72 [Jonathan] Finished Flink-928 and simplified how new pages to the WebInterface are added | 03 July 2014, 10:07:25 UTC |
| cebb1f6 | Robert Metzger | 01 July 2014, 11:46:38 UTC | add gh_link jekyll plugin to docs | 01 July 2014, 11:46:38 UTC |
| 5042280 | Fabian Hueske | 30 June 2014, 10:19:27 UTC | Minor changes in Java POJO WordCount example | 30 June 2014, 10:19:27 UTC |
| 0902829 | Raymond Liu | 30 June 2014, 08:51:19 UTC | Mention that Oracle JDK 6 library will fail to build So people won't encounter and ask the same question as I did just now ;) Author: Raymond Liu <raymond.liu@intel.com> Closes #49 from colorant/doc and squashes the following commits: 90bf2aa [Raymond Liu] Mention that Oracle JDK 6 library will fail to build | 30 June 2014, 08:51:19 UTC |
| 8980a7a | Stephan Ewen | 29 June 2014, 18:33:46 UTC | Add "how to add an operator" section to internals. Add stubs for other internals pages [ci skip] | 29 June 2014, 18:34:23 UTC |
| d76d1b0 | Stephan Ewen | 28 June 2014, 23:21:42 UTC | Fix simple error in local execution memory estimation | 28 June 2014, 23:21:42 UTC |
| c3f8809 | Stephan Ewen | 28 June 2014, 23:18:23 UTC | Add various figures for internals. Update text on internals overview. [ci skip] | 28 June 2014, 23:19:33 UTC |
| 5b390d5 | Stephan Ewen | 27 June 2014, 20:25:36 UTC | Add first files for system internals documentation [ci skip] | 27 June 2014, 20:31:49 UTC |
| 05ff333 | Stephan Ewen | 27 June 2014, 15:41:22 UTC | Add "How to contribute" and "coding guidelines" to the project. [ci skip] | 27 June 2014, 19:22:14 UTC |
| 3c5feae | Stephan Ewen | 27 June 2014, 18:37:09 UTC | Fix checkstyle errors and various warnings. | 27 June 2014, 19:22:02 UTC |
| 0d0803f | Stephan Ewen | 27 June 2014, 16:00:32 UTC | Fix the managed memory planning after patch 9ce6293075d1a2326df8a2e99c032445a555b28b | 27 June 2014, 16:10:14 UTC |
| 9ce6293 | uce | 27 June 2014, 15:38:53 UTC | Fix buggy computation of TaskManager free memory size - In NepheleMiniCluster the memory size was divided twice by the number of TaskManagers - In HardwareDescriptionFactory the memory fraction config value was multiplied too early | 27 June 2014, 15:38:53 UTC |
| f4d522b | Stephan Ewen | 27 June 2014, 11:15:26 UTC | Removed redundant config constants value. | 27 June 2014, 11:19:15 UTC |
| 3f87fc9 | Aljoscha Krettek | 27 May 2014, 15:32:36 UTC | Add support for POJO objects This adds support in the TypeExtractor and also one can now use field expressions for grouping, join, and co-group. | 26 June 2014, 09:55:10 UTC |
| 5f0a3d4 | Aljoscha Krettek | 27 May 2014, 13:36:50 UTC | Change TypeExtractor to have non-static methods that do the actual work This is required because we need state to detect recursive data types. This will become necessary when introducing Pojo Types. | 26 June 2014, 09:55:10 UTC |
| 20fdcfb | uce | 26 June 2014, 09:03:21 UTC | Reeenable tryLocalExecution() test in ClientTest | 26 June 2014, 09:03:21 UTC |
| 69589fa | Jonathan | 26 June 2014, 08:09:00 UTC | Fixed Bug Flink-978 https://issues.apache.org/jira/browse/FLINK-978 Author: Jonathan <Jonathan@Hasenburg.de> Closes #46 from JonathanH5/fixWebI and squashes the following commits: 13a7d41 [Jonathan] Fixed Bug Flink-978 | 26 June 2014, 08:09:00 UTC |
| 47239b2 | Stephan Ewen | 25 June 2014, 17:42:52 UTC | [FLINK-985] Update the config.md to properly describe the configuration settings. [ci skip] | 25 June 2014, 17:44:23 UTC |
| 9c51834 | uce | 25 June 2014, 15:53:11 UTC | Remove debug LOG message of TaskManager heartbeats | 25 June 2014, 15:53:11 UTC |
| 49cd35a | Stephan Ewen | 25 June 2014, 14:55:20 UTC | Fix generic type warnings in generated tuples | 25 June 2014, 14:55:20 UTC |
| 35438ec | Stephan Ewen | 25 June 2014, 14:52:55 UTC | InputVertices do not require an input format. | 25 June 2014, 14:52:55 UTC |
| ef623e9 | Stephan Ewen | 25 June 2014, 14:12:33 UTC | Change string construction to work around a known JVM performance bug still present in some older JVM versions. | 25 June 2014, 14:14:18 UTC |
| 8431395 | Stephan Ewen | 25 June 2014, 12:47:01 UTC | Speed up "getOptimizedPlan" by not starting the local embedded runtime. | 25 June 2014, 14:14:18 UTC |
| e2aabd9 | Markus Holzemer | 27 May 2014, 09:24:49 UTC | [FLINK-760] Add distinct operator | 25 June 2014, 13:45:29 UTC |
| 6c827fb | uce | 17 June 2014, 14:18:02 UTC | [FLINK-971] Configure PooledByteBufAllocator in NettyConnectionManager instead of using the default allocator Configuration: - 0 heap arenas, - n direct arenas (where n = num incoming + num outgoing network IO threads), and - bufferSize << 1 bytes page size. Additionally, OutboundEnvelopeEncoder directly implements ChannelOutboundHandlerAdapter instead of the MessageToByteEncoder<Envelope> wrapper to have tighter control of memory allocations. This closes #38. | 25 June 2014, 11:53:51 UTC |
| f7f1ed2 | Sebastian Kunert | 24 June 2014, 13:42:07 UTC | Update Quickstarts Java API, Run Example, and Setup Quickstart This closes #39. | 25 June 2014, 10:43:34 UTC |
| 515ad3c | Till Rohrmann | 20 June 2014, 16:17:42 UTC | [FLINK-960] Fix CollectionDataSource bug This closes #33. | 25 June 2014, 10:24:57 UTC |
| 3d6cc5f | uce | 19 June 2014, 00:42:03 UTC | [FLINK-949] Properly report GlobalBufferPool OutOfMemoryError to TaskManager This closes #28. | 25 June 2014, 10:07:16 UTC |
| 96e76a5 | Kostas Tzoumas | 13 June 2014, 15:40:24 UTC | [FLINK-926] Add shallow copy, deep equality, and hashCode to Tuple classes This closes #17. | 25 June 2014, 09:55:13 UTC |
| 28863ee | Stephan Ewen | 24 June 2014, 16:32:25 UTC | [FLINK-973] [FLINK-969] Unify, clean up, and extend all environment logging at JobManager/TaskManager startup This closes #40. | 25 June 2014, 09:04:50 UTC |
| d55ba70 | Stephan Ewen | 24 June 2014, 15:52:26 UTC | LocalExecutor automatically picks up the maximum DOP for plans as its number of slots. | 25 June 2014, 08:57:57 UTC |
| fe91d4b | Stephan Ewen | 24 June 2014, 14:06:35 UTC | Changed default number of task slots per machine to one. Add logging for task slots. | 25 June 2014, 08:57:56 UTC |
| f13ad5b | uce | 25 June 2014, 08:30:32 UTC | [FLINK-980] Fix buffer leak in OutputChannel | 25 June 2014, 08:30:32 UTC |
| 2f0bd8f | uce | 24 June 2014, 21:24:17 UTC | [FLINK-979] Fix NetworkThroughput test input and output task config - Set DummyInputFormat and DummyOutputFormat via TaskConfig to respect task hierarchy refactoring. - Run test via main method instead of JUnit test runner (this was originally a test in order to use RecordAPITestBase for JobGraph submission). This closes #41. | 25 June 2014, 08:25:54 UTC |
| f3c5428 | uce | 24 June 2014, 12:41:11 UTC | Revert unintentional change in 1357ea3a40f747e4e51b5b52612323fe55747da7 | 24 June 2014, 12:41:11 UTC |
| 1357ea3 | uce | 24 June 2014, 11:43:13 UTC | Add garbage collector stats to output of TaskManager memory usage debug thread | 24 June 2014, 11:43:13 UTC |
| 7d0e89d | Robert Metzger | 24 June 2014, 09:01:06 UTC | Show version information including commit date in TaskMgr log | 24 June 2014, 09:01:06 UTC |
| 9ff440f | Robert Metzger | 23 June 2014, 13:38:09 UTC | Add script to merge pull requests | 23 June 2014, 13:43:15 UTC |
| 40b94f7 | uce | 21 June 2014, 13:14:05 UTC | [FLINK-962] Initial import of documentation from website into source code (closes #34) | 23 June 2014, 12:51:07 UTC |
| b4b633e | Stephan Ewen | 22 June 2014, 16:19:57 UTC | Add some options for slot-based scheduling and changed default parallelism to one. | 22 June 2014, 19:09:13 UTC |
| 8c1d82a | Stephan Ewen | 20 June 2014, 19:13:23 UTC | Merge fix to omit input/output registering on JobManager Rework Invokable Task Hierarchy | 22 June 2014, 19:07:21 UTC |
| 2692643 | Till Rohrmann | 09 April 2014, 17:35:57 UTC | Standardized creation of input and output channels in InputGate and OutputGate. Removed linear contains check in InputGate for channels. | 22 June 2014, 19:07:20 UTC |
| e52fcf9 | Till Rohrmann | 09 April 2014, 14:18:44 UTC | Streamlined job graph algorithms to get rid off linear contains operations. | 22 June 2014, 19:07:20 UTC |
| fba44a9 | Till Rohrmann | 09 April 2014, 12:32:55 UTC | Replaced Tarjan's algorithm with a simpler depth-first traversal cycle detection algorithm. By doing so, one gets rid off a possible linear time check whether a node is contained in the stack. | 22 June 2014, 19:07:20 UTC |
| 93bc0b9 | Till Rohrmann | 27 March 2014, 02:01:22 UTC | Added failing behavior to JobManager if it is still in scheduled or created state New test case: Exception during ExecutionGraph construction in the JobManager Removed checkConfiguration method from AbstractJobVertex because it is not needed anymore | 22 June 2014, 19:07:20 UTC |
| ea79186 | Till Rohrmann | 26 March 2014, 01:58:15 UTC | Removed RuntimeEnvironment instantiation from execution graph construction. Removed legacy job vertex classes and input/output tasks. | 22 June 2014, 19:07:20 UTC |
| 429493d | Stephan Ewen | 18 June 2014, 22:15:46 UTC | Cleanup of merge with slot-based scheduler branch. | 22 June 2014, 19:07:20 UTC |
| 86d206c | Till Rohrmann | 01 June 2014, 14:03:27 UTC | Rework the Taskmanager to a slot based model and remove legacy cloud code Squashed commit of the following: - Post merge cleanup - Renamed fractionMemory into memoryFraction. - Removed Local and QueueScheduler and replaced it instead with an unified DefaultScheduler. - Removed Local and ClusterManager and inserted instead an unified DefaultInstanceManager. - Removed connection IDs from execution edges - Removed InstanceType, InstanceRequestMap, InstanceTypeDescription, InstanceTypeDescriptionTypeFactory, PendingRequestsMap - Fixed problems with test cases. - introduced simple slot system for scheduling. - Removed subtasks per instance - Added registerTaskManager to the JobManager RPC calls. RegisterTaskManager is called only once where the hardware description information is sent. Add: Merging cloudmodel remove with new network stack | 22 June 2014, 19:07:10 UTC |
| 7b6b5a2 | twalthr | 20 June 2014, 13:19:43 UTC | Fixes a bug where Thread.currentThread().getContextClassLoader() does not return the user code class loader within object deserialization. | 21 June 2014, 11:28:35 UTC |
| ff69b1b | Robert Metzger | 21 June 2014, 09:43:13 UTC | Hadoop Compat pull request clean-up This closes #32. | 21 June 2014, 09:44:51 UTC |
| a65b759 | twalthr | 07 May 2014, 00:54:29 UTC | The Hadoop Compatibility has been refactored and extended to support the new Java API. | 21 June 2014, 09:43:40 UTC |
| 191dd1d | Jonathan | 20 June 2014, 18:36:32 UTC | Added Version and Revision of Stratosphere in Webinterface https://issues.apache.org/jira/browse/FLINK-946  Author: Jonathan <Jonathan@Hasenburg.de> Closes #30 from JonathanH5/wi_version and squashes the following commits: f29180a [Jonathan] Added Version and Revision of Stratosphere in Webinterface | 20 June 2014, 18:36:32 UTC |
| cd665b9 | Stephan Ewen | 19 June 2014, 17:54:23 UTC | [FLINK-957] Throw meaningful warnings and exceptions upon incorrect use of delta iterations. | 20 June 2014, 13:32:20 UTC |
| 9d57045 | Kostas Tzoumas | 10 June 2014, 14:58:08 UTC | Syntactic sugar for sum, min, and max aggregations This closes #7 | 20 June 2014, 13:32:20 UTC |
| f8ec28c | Robert Metzger | 18 June 2014, 20:14:24 UTC | Re-encrypt the credentials for various services with the new apache/incubator-flink travis keys | 18 June 2014, 20:16:10 UTC |
| 9ecb6df | Stephan Ewen | 18 June 2014, 17:21:27 UTC | [FLINK-944] Consolidated serialization logic between different classes. Fixes for warnings. | 18 June 2014, 18:51:52 UTC |
| 5fa5e50 | Till Rohrmann | 17 June 2014, 17:21:02 UTC | [FLINK-944] CollectionInputFormat now uses the TypeSerializer to serialize the collection entries. This allows to use objects not implementing the Serializable interface as collection elements. This closes #25 | 18 June 2014, 17:03:18 UTC |
| f3930e3 | Kostas Tzoumas | 06 June 2014, 15:22:30 UTC | Transitive closure example in Java API This closes #24 | 18 June 2014, 16:57:22 UTC |
| b2bd469 | uce | 17 June 2014, 22:48:15 UTC | [FLINK-943] Remove leading and ending double quotes from 'env.java.opts' config value in startup scripts This closes #26 | 18 June 2014, 16:54:10 UTC |
| 6ee874a | zentol | 18 June 2014, 12:06:12 UTC | Projection constructor adjusts to max tuple size This closes #27 | 18 June 2014, 16:51:01 UTC |
| 5c23b8f | Stephan Ewen | 18 June 2014, 16:46:21 UTC | [FLINK-950] Fix spurious file deletion failures. | 18 June 2014, 16:46:21 UTC |
| 3a452e5 | Stephan Ewen | 18 June 2014, 15:07:25 UTC | [FLINk-941] Place pipeline breakers for SingleInput nodes with broadcast variables, if needed. | 18 June 2014, 16:29:11 UTC |
| 7c4c4a9 | Stephan Ewen | 17 June 2014, 23:28:34 UTC | [FLINK-940] Added additional test for cogroup with delta iteration solution set on second input. | 18 June 2014, 16:29:11 UTC |
| 1a1a13e | uce | 18 June 2014, 16:25:11 UTC | Remove Parameterized test runner annotation from NettyConnectionManagerTest | 18 June 2014, 16:25:11 UTC |
| 73a94ff | uce | 18 June 2014, 13:44:21 UTC | Add log info message with memory usage after TaskManager startup finished. This commit also introduces a logging thread, which repeatedly logs the memory usage. It can be configured via: - 'taskmanager.debug.memory.startLogThread' (default: false) - 'taskmanager.debug.memory.logIntervalMs' (default: 5000) | 18 June 2014, 14:44:06 UTC |
| b692b04 | Jonathan | 17 June 2014, 12:08:27 UTC | Fixed JSON Bug for some plans. Signed-off-by: Robert Metzger <metzgerr@web.de> This closes #23. | 18 June 2014, 10:17:04 UTC |
| 5484d58 | Robert Metzger | 18 June 2014, 10:16:11 UTC | extended plan-dump test for KMeans | 18 June 2014, 10:16:11 UTC |
| a84f8a1 | Robert Metzger | 13 June 2014, 17:46:46 UTC | Fixed error messages in web client | 18 June 2014, 09:37:28 UTC |
| e57b106 | Jonathan | 02 June 2014, 10:34:03 UTC | New Webclient This closes #15 and FLINK-711 | 18 June 2014, 09:37:28 UTC |
| 4b9c71d | Jonathan | 09 June 2014, 11:47:52 UTC | Added configuration subsection in webinterface Closes #16 (GitHub pull request) Also closes FLINK-919 | 18 June 2014, 09:37:28 UTC |
| 3c15276 | Fabian Hueske | 18 June 2014, 08:20:25 UTC | Added Zihong Cao to CONTRIBUTORS list [ci skip] This closes #21 | 18 June 2014, 08:22:49 UTC |
| 9a75e68 | Robert Metzger | 13 June 2014, 19:40:34 UTC | Do not limit the client's heap space (See FLINK-934) [ci skip] This closes #18 | 17 June 2014, 12:56:46 UTC |
| b7cbf30 | Stephan Ewen | 17 June 2014, 12:47:37 UTC | Artificial commit to close pull requests. This closes #5 This closes #6 This closes #10 This closes #12 This closes #14 | 17 June 2014, 12:47:37 UTC |
| a70de7e | uce | 13 June 2014, 08:41:32 UTC | [FLINK-930] Netty Initialization is sometimes very slow This closes #19 | 17 June 2014, 12:43:17 UTC |
| 6a54932 | uce | 16 June 2014, 20:17:48 UTC | [FLINK-942] Fix bug in config.sh to correctly set user-specified JVM args This closes #22 | 17 June 2014, 12:23:24 UTC |
| ca2b287 | Stephan Ewen | 16 June 2014, 13:05:10 UTC | [FLINK-935] (continued) Correct feedback property check for iterative algorithms. | 17 June 2014, 00:07:37 UTC |
