| 053f4c6 | Robert Metzger | 15 August 2014, 11:57:49 UTC | Commit for release 0.6-incubating | 15 August 2014, 11:57:49 UTC |
| a05c567 | Robert Metzger | 15 August 2014, 11:51:06 UTC | [FLINK-1054] Fix job history view in web frontend | 15 August 2014, 11:51:06 UTC |
| 87dd7c7 | Fabian Hueske | 14 August 2014, 14:05:06 UTC | [FLINK-1051] ./bin/start-local.bat prints error message if java.exe cannot be found | 14 August 2014, 14:43:46 UTC |
| 8fd70ae | Fabian Hueske | 14 August 2014, 13:45:59 UTC | [FLINK-1048] Swallow output of SET statements in ./bin/flink.bat | 14 August 2014, 14:43:46 UTC |
| 6a43d24 | Fabian Hueske | 14 August 2014, 13:44:24 UTC | [FLINK-1047] Fixes main class for start-local.bat | 14 August 2014, 14:43:46 UTC |
| 3856db8 | Aljoscha Krettek | 14 August 2014, 12:20:23 UTC | Add Sanity Checks for Join/CoGroup with SolutionSet in Record API We now check whether the key fields specified for the delta iterations match those specified when joining/coGrouping with the solution set. This code is more or less copied from the new Java API. The Scala API uses the Record API underneath so it is also covered. | 14 August 2014, 14:43:46 UTC |
| e44fd09 | Robert Metzger | 14 August 2014, 14:17:55 UTC | Another fix for CDH4 compliance | 14 August 2014, 14:24:01 UTC |
| cffbb4e | Stephan Ewen | 14 August 2014, 00:19:26 UTC | [FLINK-1046] Made sure that Client uses correct user-code class loaders. | 14 August 2014, 14:23:04 UTC |
| 18bcfdf | Stephan Ewen | 13 August 2014, 20:10:48 UTC | Adjusted examples packaging to only create jars for fully self-contained examples. | 14 August 2014, 09:06:00 UTC |
| f457625 | Robert Metzger | 13 August 2014, 19:21:14 UTC | Fixes on CDH4 build / Maven improvements: - remove usages of commons-lang (we use only commons-lang3, as defined in flink-runtime/pom.xml) - Upgrade maven failsafe to 2.17 so that tests also fail if the test errors (exceptions during execution) - added new build profile "docs-and-source" that creates javadocs and source attachments. These are usually only needed when releasing (--> speed up the build) | 13 August 2014, 21:14:05 UTC |
| 5b36c7e | Stephan Ewen | 13 August 2014, 19:03:17 UTC | Fix legacy names in static webclient contents | 13 August 2014, 21:13:57 UTC |
| 47e1572 | Stephan Ewen | 13 August 2014, 18:08:04 UTC | Fix problems with missing files/dependencies with cdh-4 distribution. | 13 August 2014, 21:13:57 UTC |
| 03240e9 | zentol | 07 August 2014, 11:41:11 UTC | [FLINK-966] java examples included in packaged example directory This closes #90 | 13 August 2014, 21:13:57 UTC |
| 61a3e81 | Aljoscha Krettek | 13 August 2014, 15:19:45 UTC | Change python2.7 to python in KMeans Quickstart | 13 August 2014, 21:13:57 UTC |
| 43f16c0 | Aljoscha Krettek | 13 August 2014, 10:49:37 UTC | Remove field0 from CoGroup and Join Operator These were added before to force the user to specify at least one key field. Now, the user is also forced to specify at least one key because otherwise the call would be ambiguous because of tuple key fields and expression keys. | 13 August 2014, 12:51:06 UTC |
| 451f17e | Fabian Hueske | 13 August 2014, 10:54:14 UTC | [FLINK-1042] Changed ClassLoader field to be transient. Serialization of the `RuntimeStatefulSerializerFactory` fails because the field `ClassLoader loader` is not serializable. The fix makes the field `transient`. Author: Fabian Hueske <fhueske@apache.org> Closes #92 from fhueske/StatefulSerializerFactoryFix and squashes the following commits: c01cc27 [Fabian Hueske] [FLINK-1042] Changed ClassLoader field to be transient. (cherry picked from commit eb51c8806e1e415162b7999c4d9b39e952fccc61) Signed-off-by: Robert Metzger <rmetzger@apache.org> | 13 August 2014, 10:55:25 UTC |
| 564b504 | Robert Metzger | 12 August 2014, 11:36:25 UTC | Maven now tests if files generated by the archetypes do actually build | 12 August 2014, 11:41:33 UTC |
| 4a1c28d | uce | 08 August 2014, 14:40:57 UTC | Remove expression key methods | 08 August 2014, 18:18:48 UTC |
| cb81fac | uce | 08 August 2014, 09:18:52 UTC | Disable POJO types There are various issues when working with POJOs in the Java API, for example [1]. This commit squashes the following commmits: 1. Disable tests, which depend on POJO types 2. Replace expression keys with key selector in test 3. PackagedProgramEndToEndITCase used a KMeans variant, which relies on expression keys to select the field to group on. This commit replaces this with a key selector. 4. Disable WordCountPOJO test case and package 5. Disables WordCountPOJOITCase, which executes the WordCountPOJO example. The example code is still included with the source code (with notice that it is currently not working), but will *not* be packaged as a JAR anymore. 6. Disable tests, which depend on POJO types (continued) [1] https://mail-archives.apache.org/mod_mbox/incubator-flink-dev/201407.mbox/%3C53D96049.1060509%40cse.uta.edu%3E This closes #93. | 08 August 2014, 13:29:14 UTC |
| 18f13ea | Stephan Ewen | 08 August 2014, 12:47:43 UTC | [FLINK-909] Adjust aggregators test case | 08 August 2014, 13:27:30 UTC |
| 38cbf0b | Stephan Ewen | 07 August 2014, 20:00:51 UTC | [FLINK-909] Remove additional empty (and non empty for iterative broadcast variables) superstep. [FLINK-945] Fix early memory release in iterations | 08 August 2014, 13:27:30 UTC |
| 4046e6a | Robert Metzger | 03 August 2014, 12:41:24 UTC | [doku] fix broken image urls | 06 August 2014, 09:41:45 UTC |
| e8a0857 | Kostas Tzoumas | 31 July 2014, 19:21:35 UTC | Reflect recent changes to Java API documentation change text to String This closes #87. | 06 August 2014, 09:33:33 UTC |
| 2d5f197 | Robert Metzger | 03 August 2014, 12:39:12 UTC | Fix broken history due to misplaced google load js | 06 August 2014, 09:32:33 UTC |
| 29ff613 | Robert Metzger | 30 July 2014, 17:57:21 UTC | Create release scripts, add support for "cdh4" build. | 01 August 2014, 06:06:49 UTC |
| 72d7b86 | Stephan Ewen | 29 July 2014, 13:58:44 UTC | [FLINK-1023] Switch group-at-a-time function to java.lang.Iterable (from java.util.Iterator) Iterables over transient data throw an TraversableOnceException when iterated over again. This closes #84 | 01 August 2014, 00:33:49 UTC |
| 934e4e0 | Stephan Ewen | 31 July 2014, 18:31:54 UTC | [FLINK-701] Change KeySelector to a SAM interface This closes #85 | 01 August 2014, 00:33:34 UTC |
| bc89e91 | Stephan Ewen | 31 July 2014, 17:46:14 UTC | [FLINK-701] Several cleanups after SAM refactoring. - Lambda detection compiles on earlier java versions - Add lambda detection test. - Fix JavaDocs | 31 July 2014, 18:18:00 UTC |
| 22b24f2 | Kostas Tzoumas | 18 July 2014, 13:37:19 UTC | [FLINK-701] Refactor Java API to use SAM interfaces. Introduce RichFunction stubs for all UDFs. | 31 July 2014, 15:47:35 UTC |
| 9d1c49f | Stephan Ewen | 31 July 2014, 15:25:21 UTC | [Docs] Adjust Java API documentation to be in sync with latest changes [ci skip] | 31 July 2014, 15:31:29 UTC |
| bcf85c2 | uce | 31 July 2014, 13:22:10 UTC | [Docs] Limit nesting of generated TOCs The jekyll tocify plugin generates an HTML TOC based on the headings of the markdown files. This commit limits the nesting of the TOC to 2, which means that only h1 and h2 element will be taken into account. Previously, all heading elements were used, which resulted in a very cluttered TOC. | 31 July 2014, 13:22:10 UTC |
| 23289d6 | Stephan Ewen | 31 July 2014, 00:32:37 UTC | [FLINK-1039] Fix pojo expression keys for group reduce | 31 July 2014, 12:39:06 UTC |
| 32d168f | uce | 31 July 2014, 12:16:10 UTC | Remove unused import from OutboundEnvelopeEncoderTest | 31 July 2014, 12:16:10 UTC |
| ccd4950 | uce | 31 July 2014, 09:47:41 UTC | Add type parameters in OutboundConnectionQueueTest The use of PowerMock's Whitebox without type parameters led to compile problems with Java 6. | 31 July 2014, 09:47:41 UTC |
| a45c14b | uce | 29 July 2014, 15:42:13 UTC | Update Netty dependency to 4.0.21.Final | 29 July 2014, 23:03:25 UTC |
| 5251263 | uce | 17 July 2014, 14:32:06 UTC | [FLINK-998] Close network connections when idle 1. Close idle TCP connections Tasks enqueue envelopes to be dispatched via NettyConnectionManager. The first task to enqueue an envelope triggers the establishment of a new TCP connection to the target task manager. Usually, there are multiple connections between the same task managers in order to avoid deadlocks. This commit addresses the following problem: idle connections were never closed. This meant that the number of TCP connections was monotonically increasing over time. Idling connections are now closed after a configured amount of time, see 'taskmanager.net.closeAfterIdleForMs'. 2. Enqueue envelopes directly TCP connections are handled by Netty's IO loop. Every enqueue operation needs to ensure that the envelope to be enqueued is handed over to the respective IO thread in a thread-safe manner. Previously, this was done via Netty's user events. This commit addresses the following problem: every enqueue operation resulted in the creation of an IO event loop task to hand over the envelope. Envelopes are now directly added to a ConcurrentLinkedQueue, which drastically improves the throughput of enqueue operations. The user event is now only fired to trigger the processing if the queue was empty. 3. Added unit tests for OutboundConnectionQueue and adapted existing tests to test concurrent enqueue and close 4. Removed unused arguments to NettyConnectionManager (low and high water mark) This closes #76. | 29 July 2014, 23:03:07 UTC |
| bef5e54 | Daniel Warneke | 27 July 2014, 12:30:38 UTC | [FLINK-386] Fix and clean up dependencies - Upgraded to junit 4.11 and fixed code that used deprecated - Changed scala dependency from 2.10.3 to 2.10.4 to avoid conflicts with scalatest dependency - Upgraded log4j and commons-logging dependency - Removed superfluous dependency on commons-codec - Upgraded dependency versions in the base module - Ensured consistency of avro versions across submodules - Upgraded AWS dependency to version 1.8.1 - Unified configuration of jetty dependency This closes #80. | 29 July 2014, 22:51:57 UTC |
| ac6fd75 | Stephan Ewen | 28 July 2014, 17:00:11 UTC | Fix License and Notice entries and headers for all web frontend files (css, js, fonts) | 28 July 2014, 17:00:11 UTC |
| 25b4099 | Robert Metzger | 26 July 2014, 17:05:49 UTC | [Documentation] Move "How to contrib"; "coding guidelines" out of the code repo (part of FLINK-1012) Improve build instructions with respect to Hadoop 1 and Hadoop 2 dependencies. [ci skip] | 26 July 2014, 17:06:44 UTC |
| 2e50eac | Stephan Ewen | 23 July 2014, 23:33:48 UTC | Add notice to ClosureCleaner [ci skip] | 23 July 2014, 23:36:18 UTC |
| 911f673 | uce | 23 July 2014, 07:09:39 UTC | Add ScalaTest to LICENSE file [ci skip] | 23 July 2014, 07:09:39 UTC |
| c066190 | uce | 23 July 2014, 07:05:44 UTC | Add ASM to LICENSE file [ci skip] | 23 July 2014, 07:05:44 UTC |
| dc55cc3 | Robert Metzger | 22 July 2014, 10:10:07 UTC | [FLINK-1024] Enable automated snapshot deployment through Apache's Maven infrastructure | 22 July 2014, 14:59:19 UTC |
| 3827f06 | Stephan Ewen | 21 July 2014, 14:58:04 UTC | Add Netty to License files [ci skip] | 21 July 2014, 14:58:04 UTC |
| bbff328 | Stephan Ewen | 21 July 2014, 14:52:46 UTC | Consolidate some third-party license entries, update readme in binary distribution [ci skip] | 21 July 2014, 14:53:26 UTC |
| 9fb620d | Stephan Ewen | 21 July 2014, 14:34:42 UTC | Update LICENSE and NOTICE files [ci skip] | 21 July 2014, 14:37:02 UTC |
| 05677f3 | Stephan Ewen | 21 July 2014, 10:28:25 UTC | [FLINK-1031] Fix POM files to support Eclipse | 21 July 2014, 10:28:25 UTC |
| 152dcde | Aljoscha Krettek | 17 July 2014, 11:38:56 UTC | [FLINK-1026] Fix PojoComparator Was not using the user code class loader and therefore could not clone the serializer that is internally used. Also modify KMeansForTest to make use of the PojoComparator to prevent such bugs in the future. Also fix PackagedProgramEndToEndITCase, AvroExternalJarProgramITCase and the external jar file class loader tests in flink-clients. The pom was not configured to remove the code that should only be in the external jar from the test-classes directory. | 17 July 2014, 13:31:01 UTC |
| c04c9bb | rwaury | 23 June 2014, 21:31:48 UTC | [FLINK-955] ResizingHashTable: automatic resizing, IndexOutOfBoundsException fixed, pointers This closes #57 | 16 July 2014, 16:49:51 UTC |
| 8ed2b76 | Stephan Ewen | 15 July 2014, 15:39:58 UTC | Improve exception messages for file output format when target file cannot be created. | 16 July 2014, 16:49:50 UTC |
| 5b34c0b | Stephan Ewen | 14 July 2014, 16:18:58 UTC | Fix scope for scalatest dependency | 16 July 2014, 16:49:50 UTC |
| 688f1c1 | Robert Metzger | 15 July 2014, 13:45:24 UTC | Fix Quickstart example (by using the latest 0.5.2 Stratosphere release) | 16 July 2014, 14:58:40 UTC |
| f982d40 | Robert Metzger | 13 July 2014, 13:19:58 UTC | Reconfigure Apache Rat to enforce the correct ASF license header | 15 July 2014, 18:32:53 UTC |
| 5d4590a | Sebastian Kruse | 01 July 2014, 13:22:18 UTC | [FLINK-828] Implement accumulator example - shows how to build a custom accumulator (for vectors) - employ that accumulator for obtaining filter statistics This closes #55. | 14 July 2014, 13:38:53 UTC |
| 3002258 | Stephan Ewen | 12 July 2014, 13:57:22 UTC | [FLINK-1018] Fix cross pipelining/daming info to resolve cross-related streaming deadlocks. | 12 July 2014, 17:31:26 UTC |
| ec0b00d | Stephan Ewen | 11 July 2014, 16:02:52 UTC | [FLINK-1018] Add tests to verify correct placement of pipeline breakers with broadcast variables | 12 July 2014, 17:31:26 UTC |
| a822486 | Stephan Ewen | 11 July 2014, 15:45:45 UTC | Improve error messages for data sinks inside iterations. | 12 July 2014, 17:31:26 UTC |
| ca4e7b4 | Robert Metzger | 07 July 2014, 12:02:57 UTC | [FLINK-1004] Add the maven repositories for all vendors + documentation This closes #62 | 12 July 2014, 15:36:35 UTC |
| fa9daad | Robert Metzger | 12 July 2014, 13:57:28 UTC | Fix issue with git-commit-id-plugin on Travis | 12 July 2014, 13:57:28 UTC |
| 2f3c0b9 | Robert Metzger | 11 July 2014, 17:45:07 UTC | Change cluster shutdown order to avoid heartbeat exceptions during shutdown on large clusters | 11 July 2014, 18:02:50 UTC |
| 4771efc | Robert Metzger | 11 July 2014, 17:28:16 UTC | prefix all projects in addons and quickstarts with flink- | 11 July 2014, 18:02:50 UTC |
| fbc9338 | Robert Metzger | 11 July 2014, 14:46:45 UTC | Rename documentation | 11 July 2014, 14:53:43 UTC |
| ebe6b90 | Robert Metzger | 11 July 2014, 14:25:15 UTC | Update license header for java, sh and xml files | 11 July 2014, 14:53:43 UTC |
| 7e62878 | Robert Metzger | 11 July 2014, 07:28:12 UTC | Set version to 0.6-incubating-SNAPSHOT and update Readme | 11 July 2014, 14:53:19 UTC |
| da9aa3d | Stephan Ewen | 11 July 2014, 13:42:00 UTC | Minor fixes for POM files : Inherited versions where possible, suppress unnecessary warnings | 11 July 2014, 13:42:00 UTC |
| 0f498c8 | Stephan Ewen | 11 July 2014, 13:06:32 UTC | Adjust LICENSE file to remove LGPL section (library not used any more) Adjust NOTICE file for years | 11 July 2014, 13:07:37 UTC |
| 6c9aa29 | Stephan Ewen | 10 July 2014, 18:58:36 UTC | Add compiler test for solution sets depending on the delta set. | 11 July 2014, 13:03:58 UTC |
| 8563d51 | Robert Metzger | 10 July 2014, 10:05:50 UTC | Rename POMs, scripts, quickstarts and other minor renames | 10 July 2014, 20:35:14 UTC |
| 5f01154 | Stephan Ewen | 10 July 2014, 14:46:17 UTC | Renaming part 10 (fix error in clients pom file) | 10 July 2014, 14:46:17 UTC |
| e762152 | Stephan Ewen | 09 July 2014, 23:15:01 UTC | Renaming part 9 (first part of distribution project) | 09 July 2014, 23:27:38 UTC |
| 76273ec | Stephan Ewen | 09 July 2014, 22:52:36 UTC | Renaming part 8 (addons) | 09 July 2014, 22:52:36 UTC |
| 3c08d36 | Stephan Ewen | 09 July 2014, 22:21:09 UTC | Renaming part 7 (tests) | 09 July 2014, 22:21:09 UTC |
| 45c3c44 | Stephan Ewen | 09 July 2014, 22:08:41 UTC | Refactoring part 6 (finalize scala api and scala examples) | 09 July 2014, 22:08:41 UTC |
| 43b86ad | Stephan Ewen | 09 July 2014, 21:25:19 UTC | Renaming part 5 (java examples and test utils) | 09 July 2014, 21:28:38 UTC |
| b14581c | Stephan Ewen | 09 July 2014, 20:03:10 UTC | Refactoring part 4 (compiler and clients) | 09 July 2014, 20:42:44 UTC |
| e73296f | Stephan Ewen | 09 July 2014, 18:25:27 UTC | Renaming part 3 (runtime) | 09 July 2014, 18:25:27 UTC |
| 24eb47a | Stephan Ewen | 09 July 2014, 17:14:20 UTC | Renaming part 2 (core and java api) | 09 July 2014, 17:14:20 UTC |
| 6d9a40d | Stephan Ewen | 09 July 2014, 14:08:33 UTC | Renaming part 1 (scala sources only) | 09 July 2014, 14:08:33 UTC |
| 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 |
