| be932cd | Ufuk Celebi | 27 August 2015, 21:00:01 UTC | Commit for release 0.9.1 | 27 August 2015, 21:00:01 UTC |
| 18784c9 | Stephan Ewen | 27 August 2015, 15:28:39 UTC | [build] Revert javakaffee dependency to version 0.27 to play well with ASM shading | 27 August 2015, 15:29:46 UTC |
| f196ca1 | Ufuk Celebi | 27 August 2015, 08:21:31 UTC | [docs] Bump docs to 0.9.1 | 27 August 2015, 08:21:31 UTC |
| b8834bc | Ufuk Celebi | 27 August 2015, 07:38:43 UTC | [scripts] Sync release script with master | 27 August 2015, 07:40:56 UTC |
| 9f2f6b7 | Stephan Ewen | 26 August 2015, 18:42:30 UTC | [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' | 26 August 2015, 19:12:51 UTC |
| 940a7c8 | Robert Metzger | 24 August 2015, 11:58:22 UTC | [FLINK-2386] [kafka] Add new Kafka Consumer for Flink This closes #1055 | 26 August 2015, 19:12:43 UTC |
| 3cdbb80 | Ufuk Celebi | 26 August 2015, 16:03:28 UTC | [FLINK-2356] Add shutdown hook to CheckpointCoordinator to prevent resource leaks | 26 August 2015, 17:56:45 UTC |
| eba62a6 | Stephan Ewen | 26 August 2015, 15:14:09 UTC | [FLINK-2189] [runtime] Fix various issues in hash table - check for memory availability before probing - correctly compute memory required for recursive build fast path - remove all temp files properly | 26 August 2015, 17:21:22 UTC |
| 0fe0155 | Maximilian Michels | 24 August 2015, 12:40:47 UTC | [scripts] resolve base path of symlinked executable - also adapt config.sh to use the same cross-platform compatible mechanism | 26 August 2015, 15:38:17 UTC |
| 5869bf9 | Robert Metzger | 20 August 2015, 16:43:04 UTC | [FLINK-2555] Properly pass security credentials in the Hadoop Input/Output format wrappers This is needed because the Hadoop IF/OF's are using Hadoop's FileSystem stack, which is using the security credentials passed in the JobConf / Job class in the getSplits() method. Note that access to secured Hadoop 1.x using Hadoop IF/OF's is not possible with this change. This limitation is due to missing methods in the old APIs. - Add some comments & change dependency scope to test This closes #1038. | 26 August 2015, 14:30:23 UTC |
| eb9c75f | Fabian Hueske | 30 July 2015, 19:47:01 UTC | [FLINK-2394] HadoopOutputFormats use correct OutputCommitters. | 26 August 2015, 12:26:03 UTC |
| d445a33 | Aljoscha Krettek | 26 August 2015, 10:26:56 UTC | [hotfix] Add notice about using FLINK_CONF_DIR in Yarn Setup | 26 August 2015, 10:39:39 UTC |
| 594f4f7 | Aljoscha Krettek | 25 August 2015, 17:26:29 UTC | [hotfix] Allow setting FLINK_CONF_DIR by hand | 26 August 2015, 10:39:39 UTC |
| 7e44712 | Till Rohrmann | 26 August 2015, 08:56:27 UTC | [hotfix] Fixes auto type registration settings in ExecutionConfig | 26 August 2015, 10:39:39 UTC |
| 3f2cf5a | Ufuk Celebi | 26 August 2015, 08:55:20 UTC | [FLINK-2270] [docs] Fix typo in docs (enableMonitoring => enableCheckpointing) | 26 August 2015, 10:39:38 UTC |
| 11a1cf4 | Ufuk Celebi | 19 August 2015, 14:11:13 UTC | [FLINK-2089] [runtime] Fix illegal state in RecordWriter after partition write failure - Address PR comments | 26 August 2015, 10:33:53 UTC |
| c89851d | Ufuk Celebi | 10 August 2015, 13:15:07 UTC | [FLINK-2460] [runtime] Check parent state in isReleased() check of partition view - Address PR comments | 26 August 2015, 10:22:44 UTC |
| a31f294 | Ufuk Celebi | 19 August 2015, 22:38:37 UTC | [FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union inputs The DataExchangeMode of union nodes was not respected when translating an OptimizedPlan to a JobGraph. This could result in deadlocks, when a branched data flow was closed. Union nodes with a batch exchange will propagate their exchange mode to all inputs of their inputs when the JobGraph is generated. | 21 August 2015, 15:06:00 UTC |
| c158317 | mbalassi | 11 August 2015, 13:51:30 UTC | [FLINK-2286] [streaming] ITCase for ParallelMerge behavior Closes #1014 Adapted for version 0.9 Conflicts: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/PageRankITCase.java | 19 August 2015, 12:07:22 UTC |
| 8711974 | Gábor Hermann | 06 August 2015, 13:42:54 UTC | [FLINK-2286] [streaming] Wrapped ParallelMerge into stream operator Closes #994 | 18 August 2015, 13:36:31 UTC |
| e8802f9 | Gabor Gevay | 16 August 2015, 19:40:49 UTC | [FLINK-2527] [gelly] Ensure that VertexUpdateFunction.setNewVertexValue is called at most once per updateVertex This closes #1027 | 17 August 2015, 12:18:14 UTC |
| 827efd0 | Maximilian Michels | 12 August 2015, 16:10:41 UTC | [hotfix] read from old and new parallelism config key regression of c6358024454cd8225cf27a91db7f64ffa13189ee | 12 August 2015, 16:50:33 UTC |
| bfa11ff | Gabor Gevay | 30 July 2015, 15:38:43 UTC | [FLINK-2437] handle the case of a non-public default ctor in TypeExtractor.analyzePojo Also changed some prints which printed the word "class" twice, because class.toString also prepends it to the class name. This closes #960. | 12 August 2015, 10:30:11 UTC |
| 9219dff | Stephan Ewen | 03 August 2015, 18:46:17 UTC | [FLINK-1916] [FLINK-2361] [runtime] Fix EOFException and entry loss in CompactingHashTable Also a lot of code cleanups in CompactingHashTable | 05 August 2015, 20:09:08 UTC |
| ec3b983 | twalthr | 04 August 2015, 13:30:28 UTC | [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type | 05 August 2015, 14:25:32 UTC |
| 80d3478 | Fabian Hueske | 30 July 2015, 19:44:06 UTC | [FLINK-2442] [fix] FieldPositionKeys support Pojo fields | 04 August 2015, 19:10:19 UTC |
| 8797890 | Enrique Bautista | 21 July 2015, 16:52:05 UTC | [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. Default display for 'Number of execution retries' is now 'deactivated' and for 'Job parallelism' is 'auto', as suggested in JIRA. | 04 August 2015, 19:09:54 UTC |
| acb6ea8 | buzdin | 28 July 2015, 15:45:25 UTC | [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly | 03 August 2015, 22:47:30 UTC |
| 0186a97 | Fabian Hueske | 03 August 2015, 10:04:06 UTC | Revert API-breaking change: "[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)" This reverts commit 3e31ea647c76c85cd2371427b5735cb2d9a84266. | 03 August 2015, 10:05:06 UTC |
| 012dd05 | Ufuk Celebi | 30 July 2015, 11:49:52 UTC | [FLINK-2412] [runtime] Check if parent released before querying in-memory buffer in SpillableSubpartitionView | 31 July 2015, 09:03:29 UTC |
| 3e31ea6 | Sachin Goel | 30 July 2015, 08:24:26 UTC | [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable) | 30 July 2015, 22:38:09 UTC |
| c756fe8 | Ufuk Celebi | 28 July 2015, 23:29:13 UTC | [FLINK-2424] [core] Close output stream in serialization utility | 29 July 2015, 16:40:53 UTC |
| 208c0a1 | Ufuk Celebi | 23 July 2015, 13:19:57 UTC | [FLINK-2384] [runtime] Move blocking I/O call outside of synchronized block Problem: Waiting on asynchronous write requests with the partition lock can result in a deadlock, because all other operations on the same partition are blocked. It is possible that the I/O writer itself needs to access the partition, in which cases the whole program blocks. Solution: Move the wait outside the synchronized block. This was not necessary before, because no operation assumes the spilling to be finished when the finish call has returned. | 24 July 2015, 12:00:59 UTC |
| 198406f | Ufuk Celebi | 24 July 2015, 11:42:07 UTC | [FLINK-2381] Stringify cause of ProducerFailedExceptions | 24 July 2015, 11:57:00 UTC |
| d71e65b | Ufuk Celebi | 23 July 2015, 14:45:58 UTC | [FLINK-2400] [tests] Improve error message on unexpected TaskTest message | 23 July 2015, 14:47:44 UTC |
| 6332761 | Ufuk Celebi | 16 July 2015, 14:46:17 UTC | [docs] Fix Javadocs of RuntimeContext parallel subtask index | 18 July 2015, 09:10:13 UTC |
| c7e8684 | Sebastian Kruse | 16 June 2015, 08:47:18 UTC | [FLINK-2229] Add equals() and hashCode() to ObjectArrayTypeInfo This closes #842. | 15 July 2015, 13:53:43 UTC |
| 451eb82 | Fabian Hueske | 30 June 2015, 13:11:11 UTC | [FLINK-2280] GenericTypeComparator.compare() respects ascending flag This closes #894 | 14 July 2015, 09:17:47 UTC |
| acd4317 | Fabian Hueske | 13 July 2015, 22:59:20 UTC | [FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers This closes #908 | 14 July 2015, 09:15:39 UTC |
| 055997e | Maximilian Michels | 13 July 2015, 08:50:00 UTC | [docs] fix loading of style sheet with protocol relative base URL | 13 July 2015, 08:55:16 UTC |
| 7c2a704 | Stephan Ewen | 07 July 2015, 15:01:44 UTC | [FLINK-2293] [runtime] Fix estimation for the number of hash buckets on recursive builds | 08 July 2015, 09:12:07 UTC |
| 0789460 | mbalassi | 29 June 2015, 09:17:21 UTC | [FLINK-2285] [streaming] Removed duplicate call in close from GroupedActiveDiscretizer | 02 July 2015, 14:54:01 UTC |
| d946599 | Robert Metzger | 30 June 2015, 14:56:30 UTC | [FLINK-2298] Add option to pass a custom name for Flink on YARN This closes #876 | 01 July 2015, 13:26:04 UTC |
| 9835625 | Maximilian Michels | 25 June 2015, 11:54:51 UTC | [docs] fix broken links in FAQ | 25 June 2015, 12:01:35 UTC |
| 69f858e | mbalassi | 22 June 2015, 10:45:33 UTC | [FLINK-2257] [streaming] Properly forward rich window function calls to wrapped functions Closes #855 | 25 June 2015, 11:38:56 UTC |
| d7cfa55 | Maximilian Michels | 24 June 2015, 09:31:14 UTC | [docs] correct baseurl for 0.9 documentation | 24 June 2015, 09:59:30 UTC |
| b5702c2 | Maximilian Michels | 24 June 2015, 07:48:14 UTC | [docs] correct yarn command-line example | 24 June 2015, 07:50:47 UTC |
| 9f0da5b | Maximilian Michels | 23 June 2015, 13:45:37 UTC | [FLINK-2262][utils] rename method for default integer value in ParameterTool | 24 June 2015, 07:50:44 UTC |
| 61f17f8 | Ufuk Celebi | 17 June 2015, 09:42:15 UTC | [core] Fix typo in DataSinkTask error message | 18 June 2015, 09:20:29 UTC |
| d47405b | Ufuk Celebi | 17 June 2015, 08:23:39 UTC | [streaming] Fix out-of-sync class-level docs of SourceFunction | 18 June 2015, 09:20:15 UTC |
| bbd08f3 | Maximilian Michels | 18 June 2015, 08:20:18 UTC | Revert "[FLINK-2203] handling null values for RowSerializer" This reverts commit adc3e0e6b1d2013c522e55ee027927488bde09f2. | 18 June 2015, 08:20:18 UTC |
| d6ad294 | Maximilian Michels | 18 June 2015, 08:20:10 UTC | Revert "[FLINK-2210] Table API support for aggregation on columns with null values" This reverts commit 0914a7d0a8f564c26b6b9c0f37e8685db5d880ed. | 18 June 2015, 08:20:10 UTC |
| 0914a7d | Shiti | 14 June 2015, 18:59:02 UTC | [FLINK-2210] Table API support for aggregation on columns with null values | 16 June 2015, 22:51:17 UTC |
| adc3e0e | Shiti | 12 June 2015, 15:25:48 UTC | [FLINK-2203] handling null values for RowSerializer This closes #831 | 16 June 2015, 22:51:17 UTC |
| fa02e5f | mjsax | 05 June 2015, 18:35:45 UTC | [FLINK-2174] allow comments in 'slaves' file This closes #796. | 16 June 2015, 22:51:16 UTC |
| 44b969e | Maximilian Michels | 15 June 2015, 14:37:35 UTC | [FLINK-2226][YARN] fail application on failed single-job cluster job Failing jobs executed in the YARN cluster mode leave the application container in the "SUCCEEDED" final state. While for long-running Flink YARN clusters where multiple jobs are run, this is fine, for single jobs it is appropriate to mark the application as failed. This closes #838. | 16 June 2015, 22:51:16 UTC |
| 57810b5 | mbalassi | 16 June 2015, 13:16:28 UTC | [build] merge transitive notice files to shaded notices This closes #837. | 16 June 2015, 22:50:55 UTC |
| 57955d9 | mjsax | 15 June 2015, 20:12:47 UTC | [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex This closes #840. | 16 June 2015, 22:49:35 UTC |
| 6a9782a | Till Rohrmann | 11 June 2015, 13:00:07 UTC | [legal] Updates LICENSE/NOTICE file of source and binary distribution This closes #830. | 16 June 2015, 21:42:39 UTC |
| d690633 | Till Rohrmann | 16 June 2015, 10:27:02 UTC | [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Conflicts: flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java | 16 June 2015, 21:42:20 UTC |
| 0a8142a | Fabian Hueske | 16 June 2015, 20:11:21 UTC | [hotfix] Removed execute() that followed print() in quickstart wordcount jobs | 16 June 2015, 20:13:12 UTC |
| 2359b49 | mbalassi | 14 June 2015, 20:24:52 UTC | [docs] Update obsolate cluster execution guide Closes #835 | 16 June 2015, 11:07:41 UTC |
| c2b1e12 | mbalassi | 14 June 2015, 20:21:43 UTC | [FLINK-2209] [docs] Document linking with jars not in the binary dist | 16 June 2015, 11:07:30 UTC |
| ccaa0b0 | mbalassi | 15 June 2015, 16:53:08 UTC | [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup This is just a clear documentation of the problem for the 0.9 release. Closes #839 | 16 June 2015, 11:07:19 UTC |
| d147c71 | Aljoscha Krettek | 16 June 2015, 08:19:46 UTC | [hotfix] Some small fixups in README.md This closes #841. | 16 June 2015, 08:38:12 UTC |
| a300eec | Ufuk Celebi | 16 June 2015, 08:30:07 UTC | [FLINK-2219] [webfrontend] Fix IllegalArgumentException and decrease log level - Pressing the state button in the job history view (like SCHEDULED, FINISHED) sends a "null" (String) as group vertex ID, which results in an IllegalArgumentException. Fixed by check and early return. - The JM log is flooded by INFO-level messages when no GlobalJobParameters are set (common case). Fixed by decreasing the log level of these message to DEBUG. | 16 June 2015, 08:34:54 UTC |
| c4f3f48 | Ufuk Celebi | 15 June 2015, 15:22:38 UTC | [FLINK-2224] Log error cause in JobStatusChange | 15 June 2015, 15:22:38 UTC |
| 8232809 | Ufuk Celebi | 15 June 2015, 11:05:01 UTC | [FLINK-2216] Exclude javadoc jar from examples | 15 June 2015, 11:05:01 UTC |
| b342cf7 | Ufuk Celebi | 15 June 2015, 09:56:50 UTC | [readme] Synchronize tagline with intro, fix typos | 15 June 2015, 09:58:18 UTC |
| f5f0709 | Till Rohrmann | 09 June 2015, 14:11:05 UTC | [FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface This closes #814. | 12 June 2015, 12:28:52 UTC |
| 40e2df5 | Theodore Vasiloudis | 05 June 2015, 09:09:11 UTC | [FLINK-2072] [ml] Adds quickstart guide This closes #792. | 12 June 2015, 12:27:29 UTC |
| af0fee5 | Fabian Hueske | 12 June 2015, 09:36:03 UTC | [FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency. This closes #829 | 12 June 2015, 12:27:03 UTC |
| e513be7 | Fabian Hueske | 11 June 2015, 23:45:03 UTC | [FLINK-2206] Fix incorrect counts of finished, canceled, and failed jobs in webinterface This closes #826 | 12 June 2015, 12:26:47 UTC |
| ecfde6d | Maximilian Michels | 12 June 2015, 11:04:21 UTC | [docs][release] update stable version to 0.9.0 | 12 June 2015, 11:28:53 UTC |
| 4d8ae1c | Maximilian Michels | 12 June 2015, 11:03:31 UTC | [docs] remove obsolete YARN link and cleanup download links | 12 June 2015, 11:28:53 UTC |
| f27fc81 | Ufuk Celebi | 10 June 2015, 08:42:42 UTC | [FLINK-2195] Configure Configurable Hadoop InputFormats This closes #828. | 12 June 2015, 09:51:48 UTC |
| ce3bc9c | mbalassi | 11 June 2015, 10:27:21 UTC | [streaming] [api-breaking] Minor DataStream cleanups - Removed unused constructor parameter. - Updated outdated and wrong connection javadocs. Closes #825 | 12 June 2015, 08:05:30 UTC |
| 0edc0c8 | mbalassi | 10 June 2015, 14:09:14 UTC | [build] [streaming] Streaming parents dependencies pushed to children Closes #820 | 12 June 2015, 08:05:19 UTC |
| 6380b95 | mbalassi | 10 June 2015, 12:46:11 UTC | [streaming] Logging update for checkpointed streaming topologies Also adding a log message when delaying the retry of the execution graph. Closes #819 | 12 June 2015, 08:05:12 UTC |
| 5993e28 | Fabian Hueske | 10 June 2015, 15:43:05 UTC | [FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel. This closes #821 | 12 June 2015, 07:48:35 UTC |
| 80dd72d | Fabian Hueske | 10 June 2015, 09:58:08 UTC | [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class This closes #817 | 12 June 2015, 07:48:34 UTC |
| c8c2e2c | Aljoscha Krettek | 10 June 2015, 08:59:42 UTC | [hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync | 12 June 2015, 07:48:34 UTC |
| 77def9f | Maximilian Michels | 11 June 2015, 11:27:23 UTC | [FLINK-2183][runtime] fix deadlock for concurrent slot release | 11 June 2015, 14:56:26 UTC |
| 87988ae | Maximilian Michels | 10 June 2015, 16:18:02 UTC | [scripts] remove quickstart scripts - we already decided to host them on the website - not really useful and they need maintenance - having the snapshot quickstart in the source is against Apache rules | 11 June 2015, 12:02:31 UTC |
| f3a96de | mbalassi | 10 June 2015, 09:32:45 UTC | [streaming] Fixed streaming example jars packaging and termination Closes #816 | 10 June 2015, 15:20:45 UTC |
| 255c554 | Aljoscha Krettek | 09 June 2015, 14:17:48 UTC | [FLINK-2191] Fix inconsistent use of closure cleaner in Scala Streaming The closure cleaner still cannot be disabled for the Timestamp extractor in Time and for the delta function in Delta (windowing helpers). Closes #813 | 10 June 2015, 15:20:36 UTC |
| 1343f26 | Gyula Fora | 10 June 2015, 13:33:58 UTC | [streaming] Allow force-enabling checkpoints for iterative jobs | 10 June 2015, 13:37:15 UTC |
| c59d291 | Gabor Gevay | 09 June 2015, 13:10:35 UTC | Fixed a few trivial issues: - The description of the input format for the graph examples showed an example input as having a newline at the end of the last line, but CsvInputFormat doesn't allow that (it says "Row too short" for the empty line). - Fixed a link to local_execution.html in a javadoc. - ConcatenatedExtract had a typo in its name. - The creation of the jar for the SessionWindowing example was missing from the pom. Closes #809 | 10 June 2015, 09:40:06 UTC |
| e0e6f59 | Gyula Fora | 09 June 2015, 18:13:13 UTC | [streaming] Optional iteration feedback partitioning added Closes #810 | 09 June 2015, 19:06:18 UTC |
| 348ac86 | Aljoscha Krettek | 09 June 2015, 12:56:17 UTC | [hotfix] Fix YARNSessionFIFOITCase When comparing the hostname, it was comparing capitalised vs. all-lowercase hostname from the yarn config. | 09 June 2015, 12:58:30 UTC |
| 80cf2c5 | Till Rohrmann | 09 June 2015, 08:23:09 UTC | [ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme. | 09 June 2015, 08:35:57 UTC |
| c83ee8a | fobeligi | 05 June 2015, 21:12:43 UTC | [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation. This closes #798. | 09 June 2015, 08:35:42 UTC |
| ee7c417 | mbalassi | 08 June 2015, 16:08:52 UTC | [docs] [streaming] Added states and fold to the streaming docs | 08 June 2015, 17:02:55 UTC |
| fcca75c | Gabor Gevay | 08 June 2015, 11:42:29 UTC | [docs] Fix some typos and grammar in the Streaming Programming Guide. Closes #806 | 08 June 2015, 17:02:55 UTC |
| ce3dd36 | Maximilian Michels | 08 June 2015, 14:57:43 UTC | [hotfix] correct Maven dependency for streaming examples | 08 June 2015, 14:57:43 UTC |
| 26304c2 | Aljoscha Krettek | 08 June 2015, 09:32:27 UTC | [FLINK-2054] Add object-reuse switch for streaming The switch was already there: enableObjectReuse() in ExecutionConfig. This was simply not considered by the streaming runtime. This change now draws a copy before forwarding an element to a chained operator when object reuse is disabled. | 08 June 2015, 14:00:05 UTC |
| 7805db8 | Cheng Hao | 04 June 2015, 15:17:35 UTC | [FLINK-2000][table] Add SQL-style Aggregation Support | 08 June 2015, 13:37:15 UTC |
| 804430b | Maximilian Michels | 05 June 2015, 13:36:28 UTC | [FLINK-1635] remove Apache Thrift and Google Protobuf dependencies - remove Maven dependencies - add docs to show how to register your own serializer with Kryo This closes #794. | 08 June 2015, 09:20:13 UTC |
| 3e9af82 | Christian Wuerz | 04 June 2015, 18:05:46 UTC | [FLINK-2080] Document how to use Flink with sbt Closes #787 | 08 June 2015, 09:10:08 UTC |
| 80b1d56 | Robert Metzger | 04 June 2015, 11:45:48 UTC | Add CONTRIBUTING.md file with pointers to our guides Closes #778 | 08 June 2015, 09:10:08 UTC |
