| f3a6b5f | Ufuk Celebi | 06 May 2016, 12:58:02 UTC | Commit for release 1.0.3 | 06 May 2016, 12:58:02 UTC |
| 115d12a | Ufuk Celebi | 06 May 2016, 12:46:02 UTC | [docs] Add note about S3AFileSystem 'buffer.dir' property | 06 May 2016, 12:46:32 UTC |
| 4d3dcb1 | Ufuk Celebi | 04 May 2016, 08:38:04 UTC | [FLINK-3860] [connector-wikiedits] Add retry loop to WikipediaEditsSourceTest This closes #1964. | 04 May 2016, 11:38:41 UTC |
| 0708dd0 | Ufuk Celebi | 29 April 2016, 09:22:33 UTC | Revert "[FLINK-3800] [jobmanager] Terminate ExecutionGraphs properly" This reverts commit 014a686ec5ea0e8809a5235fe988f828e5e70833. | 29 April 2016, 09:22:33 UTC |
| f1d34b1 | Gyula Fora | 20 April 2016, 20:22:55 UTC | [FLINK-3790] [streaming] Use proper hadoop config in rolling sink Closes #1919 | 28 April 2016, 19:54:41 UTC |
| 81c69f9 | Aljoscha Krettek | 28 April 2016, 08:02:26 UTC | [FLINK-3840] Remove Testing Files in RocksDB Backend We create random files on initialization to check whether we can write to the data directory. These files are also removed now. | 28 April 2016, 12:15:58 UTC |
| 4a34f6f | Fabian Hueske | 27 April 2016, 12:44:56 UTC | [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names. | 27 April 2016, 14:01:29 UTC |
| 014a686 | Till Rohrmann | 21 April 2016, 15:07:51 UTC | [FLINK-3800] [jobmanager] Terminate ExecutionGraphs properly This PR terminates the ExecutionGraphs properly without restarts when the JobManager calls cancelAndClearEverything. It is achieved by allowing the method to be only called with an SuppressRestartsException. The SuppressRestartsException will disable the restart strategy of the respective ExecutionGraph. This is important because the root cause could be a different exception. In order to avoid race conditions, the restart strategy has to be checked twice whether it allwos to restart the job: Once before and once after the job has transitioned to the state RESTARTING. This avoids that ExecutionGraphs can become an orphan. Furhtermore, this PR fixes the problem that the default restart strategy is shared by multiple jobs. The problem is solved by introducing a RestartStrategyFactory which creates for every job its own instance of a RestartStrategy. Fix LeaderChangeJobRecoveryTest case This closes #1923. | 27 April 2016, 12:46:35 UTC |
| c2f480d | Ufuk Celebi | 27 April 2016, 12:36:21 UTC | [streaming-contrib] Fix port clash in DbStateBackend tests | 27 April 2016, 12:36:21 UTC |
| d8feb15 | Till Rohrmann | 26 April 2016, 15:39:47 UTC | [hotfix] OptionSerializer.duplicate to respect stateful element serializer | 26 April 2016, 16:18:34 UTC |
| 7062b0a | Ufuk Celebi | 26 April 2016, 08:30:46 UTC | [FLINK-3803] [runtime] Pass CheckpointStatsTracker to ExecutionGraph Backport of 8330539. `CheckpointStatsTracker` was instantiated in `ExecutionGraph#enableSnapshotCheckpointing`, where the Flink configuration is not available to parse the configuration. Instead of instantiating the `CheckpointStatsTracker` in the `ExecutionGraph` method, we directly pass it to it. | 26 April 2016, 08:31:02 UTC |
| f80f6d6 | Stefano Baghino | 29 March 2016, 17:10:46 UTC | [FLINK-3678] [dist, docs] Make Flink logs directory configurable * Edit config.sh * Document the newly defined log directory configuration key This closes #1837 | 25 April 2016, 10:17:38 UTC |
| 08361a9 | Ufuk Celebi | 22 April 2016, 16:02:02 UTC | [docs] Update version to 1.0.2 | 22 April 2016, 16:02:02 UTC |
| f745299 | Ufuk Celebi | 20 April 2016, 12:08:34 UTC | [docs] Update AWS S3 docs | 20 April 2016, 12:09:05 UTC |
| 344a55e | Till Rohrmann | 19 April 2016, 16:37:32 UTC | [hotfix] [cep] Make cep window border treatment consistent The NFA and the SharedBuffer treated window borders differently. Therefore, it was possible that events were pruned even though the NFA still contained references to these events. Now CEP windows are left inclusive and right exclusive. | 20 April 2016, 09:04:01 UTC |
| 5987eb6 | smarthi | 15 April 2016, 19:44:00 UTC | [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public' This closes #1829 | 18 April 2016, 10:41:59 UTC |
| c1eb247 | spkavuly | 13 April 2016, 19:02:57 UTC | [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs Java 8 update 11 introduced a stricter bytecode verifier that leads to failures in unit tests that use the PowerMock runner. The tests run correctly in Java 8u51 or above. | 15 April 2016, 12:08:24 UTC |
| b4b08ca | Andrew Palumbo | 14 April 2016, 18:25:46 UTC | [FLINK-3762] [core] Enable Kryo reference tracking | 15 April 2016, 12:08:21 UTC |
| 5b69dd8 | Tianji Li | 11 April 2016, 17:56:34 UTC | [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals() | 15 April 2016, 12:07:42 UTC |
| aadc5fa | Aljoscha Krettek | 14 April 2016, 14:10:06 UTC | [FLINK-3760] Fix StateDescriptor.readObject | 14 April 2016, 16:09:56 UTC |
| ea50ed3 | Todd Lisonbee | 08 April 2016, 00:47:19 UTC | [FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker() will pass before JUnit timeout This closes #1864 | 13 April 2016, 08:48:39 UTC |
| ff38202 | Aljoscha Krettek | 12 April 2016, 08:46:59 UTC | [FLINK-3730] Fix RocksDB Local Directory Initialization | 13 April 2016, 08:38:11 UTC |
| 4f9c198 | Robert Metzger | 07 April 2016, 14:44:48 UTC | [FLINK-3712] Make all dynamic properties available to the CLI frontend This closes #1863 | 11 April 2016, 14:49:15 UTC |
| 0e43ce9 | Greg Hogan | 06 April 2016, 19:44:47 UTC | [FLINK-3469] [docs] Improve documentation for grouping keys This closes #1858. | 11 April 2016, 12:20:55 UTC |
| 62e811f | Greg Hogan | 18 March 2016, 14:44:03 UTC | [FLINK-3634] [docs] Fix documentation for DataSetUtils.zipWithUniqueId() This closes #1817. | 11 April 2016, 12:20:55 UTC |
| 1554c9b | Konstantin Knauf | 03 April 2016, 11:57:35 UTC | [FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore | 08 April 2016, 13:54:39 UTC |
| 43093e3 | Robert Metzger | 05 April 2016, 12:48:40 UTC | [FLINK-3697] Properly access type information for nested POJO key selection This closes #1851 | 08 April 2016, 08:40:25 UTC |
| 17909aa | Aljoscha Krettek | 22 March 2016, 17:08:15 UTC | [FLINK-3654] Disable Write-Ahead-Log in RocksDB State | 07 April 2016, 10:21:04 UTC |
| a057465 | Shannon Carey | 07 April 2016, 04:30:38 UTC | [FLINK-3711][docs] Documentation of Scala fold()() uses correct syntax Closes #1860 | 07 April 2016, 08:55:12 UTC |
| 9d3dc71 | Ufuk Celebi | 06 April 2016, 11:56:29 UTC | [docs] Bump Flink version to 1.0.1 | 06 April 2016, 11:56:29 UTC |
| ddc07c1 | Ufuk Celebi | 06 April 2016, 10:18:44 UTC | [docs] Add back pressure monitoring page | 06 April 2016, 10:24:26 UTC |
| cb32004 | Ufuk Celebi | 05 April 2016, 18:48:22 UTC | [docs] Add missing license to new page | 05 April 2016, 18:49:34 UTC |
| 73856f3 | Ufuk Celebi | 05 April 2016, 17:11:53 UTC | [docs] Fix broken links in Concepts | 05 April 2016, 17:12:33 UTC |
| eb5cf4d | Ufuk Celebi | 05 April 2016, 17:06:56 UTC | [docs] Remove obsolete Flink on Tez figures | 05 April 2016, 17:12:33 UTC |
| 0bd0bb4 | Ufuk Celebi | 05 April 2016, 17:06:24 UTC | [docs] Add separate AWS setup page | 05 April 2016, 17:12:33 UTC |
| a76cefc | kl0u | 17 March 2016, 11:37:30 UTC | [hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs This closes #1811 | 04 April 2016, 19:34:41 UTC |
| e0dc5c1 | Ufuk Celebi | 10 March 2016, 11:02:25 UTC | [FLINK-3595] [runtime] Eagerly destroy buffer pools on cancelling | 04 April 2016, 19:28:07 UTC |
| f40ffd7 | Aljoscha Krettek | 04 April 2016, 08:44:35 UTC | [hotfix] Fix some typos in "concepts" doc | 04 April 2016, 16:59:11 UTC |
| 9e5f59a | Ufuk Celebi | 04 April 2016, 16:04:54 UTC | [docs] Remove JS from concepts page | 04 April 2016, 16:05:35 UTC |
| a3fc74b | Maximilian Michels | 04 April 2016, 12:21:14 UTC | [FLINK-3638][docs] fix default task manager port | 04 April 2016, 12:29:55 UTC |
| 486dd93 | Ufuk Celebi | 04 April 2016, 10:01:43 UTC | [docs] Move quickstart top nav link - User reported too wide page with quickstart and concepts - Moved setup, Scala, Java quickstarts to setup section - Moved wikiedits example to streaming guide - Quickstarts are linked as before from the project page | 04 April 2016, 10:01:44 UTC |
| f0aec61 | Ufuk Celebi | 04 April 2016, 08:45:52 UTC | [docs] Rename Guides->Concepts to API Concepts | 04 April 2016, 08:46:15 UTC |
| 2de3626 | Ufuk Celebi | 04 April 2016, 08:39:02 UTC | [docs] Add top-nav link to concepts | 04 April 2016, 08:42:08 UTC |
| cbb2e00 | Ufuk Celebi | 04 April 2016, 08:14:07 UTC | [docs] Add top links and sub headings to Concepts | 04 April 2016, 08:42:08 UTC |
| 7f41dd6 | Stephan Ewen | 31 March 2016, 17:25:35 UTC | [docs] Add "concepts" documentation page | 04 April 2016, 08:42:03 UTC |
| 974c66e | Ufuk Celebi | 31 March 2016, 10:08:10 UTC | [FLINK-3383] Backport 'Move snapshot deployment from Travis CI to ASF Jenkins' | 31 March 2016, 10:19:19 UTC |
| 630e77f | Till Rohrmann | 31 March 2016, 09:35:19 UTC | [FLINK-3684] [cep] Add proper watermark emission to CEP operators This closes #1842. | 31 March 2016, 09:46:47 UTC |
| dae29b4 | Till Rohrmann | 30 March 2016, 13:27:21 UTC | [FLINK-3682] [cep] Assign processing timestamp in CEP operators This PR fixes the problem that the CEP operators did not assign the wall clock time as the timestamp to incoming in StreamRecords if the TimeCharacteristic was set to ProcessingTime. Processing element with a Long.MIN_VALUE timestamp can lead to underflows in the NFA if a positive window length is subtracted from the timestamp. For this underflow a sanity check has been added to notify the user with an exception about it. This closes #1841. | 30 March 2016, 17:19:52 UTC |
| a96e1a6 | Till Rohrmann | 30 March 2016, 12:55:27 UTC | [FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas The TypeExtractor.getUnaryOperatorReturnType and TypeExtractor.getBinaryOperatorReturnType methods have been extended to support positional arguments for the input types. This allows to support parameterized types as Java 8 lambda arguments where the input type is not specified by the first type argument (e.g. Map<String, T>). This also solves the problem that the CEP library did not support Java 8 lambdas as select functions. This closes #1840. | 30 March 2016, 17:19:48 UTC |
| ce448cd | Ufuk Celebi | 30 March 2016, 14:54:45 UTC | [tools] Update copy files function in release script - people.apache.org has moved to home.apache.org - rsync currently not supported | 30 March 2016, 14:57:09 UTC |
| 245f0d8 | Till Rohrmann | 30 March 2016, 14:04:37 UTC | [hotfix] [cep] Add sanity check for erroneously pruned elements | 30 March 2016, 14:06:36 UTC |
| 2089029 | Aljoscha Krettek | 07 March 2016, 16:15:20 UTC | [FLINK-3651] Fix faulty RollingSink Restore On restore the sink for subtask index i has to cleanup leftover files for subtask i. The pattern used for checking this was not properly terminated so the sink for subtask 1 would, for example, delete some files for sink i=11. This would lead to data loss. | 29 March 2016, 17:14:15 UTC |
| 875cb44 | Maximilian Michels | 29 March 2016, 13:46:23 UTC | [FLINK-3676][docs] sync docs with the WebClient removal | 29 March 2016, 13:49:02 UTC |
| 085f7b2 | Niels Zeilemaker | 23 March 2016, 15:40:25 UTC | [FLINK-3663] [kafka] Fix logPartitionInfo log statement This closes #1835. | 24 March 2016, 10:59:02 UTC |
| 5357ebe | Stefano Baghino | 22 March 2016, 16:17:32 UTC | [FLINK-3653] [docs] Add recovery.zookeeper.storageDir docs to config page This closes #1828. | 24 March 2016, 10:55:17 UTC |
| 1ca4f36 | Martin Liesenberg | 11 February 2016, 23:18:06 UTC | [FLINK-2444] Add tests for HadoopInputFormats | 23 March 2016, 16:37:31 UTC |
| da989c4 | Martin Liesenberg | 11 February 2016, 14:59:01 UTC | [FLINK-2445] Improve HadoopOutputFormatTests | 23 March 2016, 16:37:15 UTC |
| edf343a | Ajay Bhat | 06 January 2016, 10:42:03 UTC | [FLINK-2445] Add tests for HadoopOutputFormats | 23 March 2016, 16:36:57 UTC |
| 1909bdb | Robert Metzger | 07 December 2015, 14:45:57 UTC | [FLINK-3129] Bring infrastructure for ensuring interface stability in place | 23 March 2016, 14:26:26 UTC |
| cd5773e | ramkrishna | 21 March 2016, 11:33:42 UTC | [FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator | 22 March 2016, 12:58:04 UTC |
| 0880c59 | twalthr | 14 March 2016, 12:36:51 UTC | [FLINK-3602] Fix TypeExtractor and add support for recursive types | 22 March 2016, 12:58:01 UTC |
| 954cdc1 | Aljoscha Krettek | 21 March 2016, 09:57:10 UTC | [hotfix] Fix ContinuousProcessingTimeTrigger | 21 March 2016, 10:13:59 UTC |
| 2c78be3 | Li Fanxi | 17 March 2016, 06:49:42 UTC | [FLINK-3629] Fix quick start description for the ".timeWindow()" function call | 17 March 2016, 13:10:23 UTC |
| 6749874 | Fabian Hueske | 16 March 2016, 12:58:39 UTC | [FLINK-3621] [docs] Improve documentation of memory configuration parameters This closes #1801 | 16 March 2016, 13:18:24 UTC |
| 165065c | Fabian Hueske | 26 February 2016, 13:29:25 UTC | [FLINK-3333] [docs] Improve documentation of DataSet object-reuse modes. | 14 March 2016, 09:53:05 UTC |
| 3d8c7c1 | zentol | 09 March 2016, 10:11:31 UTC | [FLINK-3472] [jdbc] Give a better exception if jdbc column has a null value This closes #1772 | 13 March 2016, 16:29:03 UTC |
| 43e95f2 | Stephan Ewen | 11 March 2016, 14:30:32 UTC | [FLINK-2671] [tests] Fix test instability in StreamCheckpointNotifierITCase Also add more logging, to help future test debugging | 11 March 2016, 14:55:50 UTC |
| f905503 | Stephan Ewen | 10 March 2016, 20:30:49 UTC | [FLINK-3594] [runtime] Make sure exceptions during checkpoints are handled properly - For the asynchronous trigger, exceptions are suppressed if the task is no longer running - The task cannot go to "not running" while a checkpoint is still in progress. | 11 March 2016, 14:53:18 UTC |
| a405b55 | Ufuk Celebi | 11 March 2016, 14:05:53 UTC | [hotfix] [runtime] Guard async recovery operation in try-catch If something fails during a RecoverJobGraph, the logs don't show anything. | 11 March 2016, 14:31:07 UTC |
| 5f35d13 | Maximilian Michels | 11 March 2016, 09:39:24 UTC | [quickstart] fix links to documentation | 11 March 2016, 09:44:37 UTC |
| dc675f2 | Ufuk Celebi | 10 March 2016, 09:29:48 UTC | [docs] Remove 'Working with Time' page Superseded by new 'Event Time' section. | 10 March 2016, 09:31:21 UTC |
| 95cd07c | Stephan Ewen | 09 March 2016, 19:31:52 UTC | [docs] Add description and illustration about Watermarks in streams | 09 March 2016, 19:38:56 UTC |
| 2831b7d | Ufuk Celebi | 08 March 2016, 18:53:38 UTC | [docs] Add first steps to docs start page | 08 March 2016, 18:54:21 UTC |
| a709f0a | Ufuk Celebi | 08 March 2016, 18:28:03 UTC | [docs] Update stack figure on docs start page | 08 March 2016, 18:28:03 UTC |
| bb9c1fa | Ufuk Celebi | 08 March 2016, 17:40:51 UTC | [FLINK-3592] [docs] Update setup quickstart | 08 March 2016, 17:44:02 UTC |
| d4c2a47 | Aljoscha Krettek | 08 March 2016, 14:49:09 UTC | [FLINK-3591] Replace Quickstart K-Means Example by Streaming Example | 08 March 2016, 16:16:05 UTC |
| 2f3711b | Ufuk Celebi | 07 March 2016, 10:21:42 UTC | [docs] Move connectors page to batch guide | 08 March 2016, 15:01:52 UTC |
| db860e4 | Ufuk Celebi | 08 March 2016, 14:59:36 UTC | Update version and remove unused variables | 08 March 2016, 14:59:36 UTC |
| 4f6a92d | Maximilian Michels | 07 March 2016, 09:45:24 UTC | [docs] update "build from source" page | 07 March 2016, 09:57:15 UTC |
| a08242f | vasia | 06 March 2016, 11:53:21 UTC | [FLINK-3533] [docs] fix broken links to examples and cluster execution in Gelly guide | 06 March 2016, 12:01:36 UTC |
| b376540 | twalthr | 03 March 2016, 14:44:28 UTC | [FLINK-3566] [FLINK-3563] [core] TypeExtraction input type validation fixes This closes #1759 | 04 March 2016, 19:53:44 UTC |
| 2cde19b | zentol | 25 February 2016, 13:31:34 UTC | [FLINK-3495] [tests] Disable RocksDB tests on Windows This closes #1711 | 04 March 2016, 19:53:44 UTC |
| 5a63cbf | zentol | 24 February 2016, 10:14:23 UTC | [FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows This closes #1703 | 04 March 2016, 19:53:44 UTC |
| 0e61ffc | Stephan Ewen | 03 March 2016, 20:21:05 UTC | [docs] Add documentation about Event Time, Timestamp Assigners, Watermark Generation | 04 March 2016, 19:53:44 UTC |
| 5c3c734 | Aljoscha Krettek | 03 March 2016, 15:53:53 UTC | [FLINK-3575] [docs] Update 'Working With State' section in docs This closes #1760 | 04 March 2016, 19:53:44 UTC |
| 9158789 | Stephan Ewen | 04 March 2016, 11:23:45 UTC | [FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction This also consolidates the various wrapper classes for fold() and reduce() functions. This closes #1765 | 04 March 2016, 19:53:44 UTC |
| fd0830e | Maximilian Michels | 03 March 2016, 11:52:32 UTC | [FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes | 04 March 2016, 16:55:38 UTC |
| b289311 | Till Rohrmann | 03 March 2016, 13:24:42 UTC | [FLINK-3570] [runtime] Use InetAddress.getLocalHost() as heuristic to find local address The ConnectionUtils.findAddressUsingStrategy method tries to find out the local address which is accessible by other machines of the cluster. It tries to connect to a specified address to do so. In case that the no connection could be established, it uses an heuristic. Before it randomly picked a NetworkInterface which is bound to an Inet4Address, not a loop back address and not a link local address. In most cases it makes more sense to default to the InetAddress.getLocalHost() address instead. This PR replaces the old heuristic with simply returning the InetAddress.getLocalHost(). This of course requires that the system on which Flink is running, is properly configured. This closes #1758. | 04 March 2016, 09:36:01 UTC |
| f856855 | Aljoscha Krettek | 03 March 2016, 16:08:22 UTC | [FLINK-3484] Add setSlotSharingGroup documentation | 03 March 2016, 16:10:21 UTC |
| 7e6c2ec | Stephan Ewen | 03 March 2016, 10:13:13 UTC | [hotfix] Fix JavaDocs for SourceFunction | 03 March 2016, 10:23:36 UTC |
| a79521f | Robert Metzger | 03 March 2016, 08:32:40 UTC | [hotfix] Make 'force-shading' deployable | 03 March 2016, 08:32:40 UTC |
| 3adc514 | Maximilian Michels | 02 March 2016, 16:52:05 UTC | [maven] add module to force execution of Shade plugin This ensures that all properties of the root pom are properly resolved by running the Shade plugin. Thus, our root pom does not have to depend on a Scala version just because it holds the Scala version properties. | 02 March 2016, 18:55:19 UTC |
| b862fd0 | Márton Balassi | 21 February 2016, 22:01:00 UTC | [FLINK-3422][streaming] Update tests reliant on hashing | 02 March 2016, 11:47:23 UTC |
| a049d80 | Gabor Horvath | 21 February 2016, 13:54:44 UTC | [FLINK-3422][streaming][api-breaking] Scramble HashPartitioner hashes. | 02 March 2016, 11:47:10 UTC |
| 23dc2a4 | Stephan Ewen | 29 February 2016, 18:24:34 UTC | [FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type parsing This closes #1744 | 01 March 2016, 16:24:41 UTC |
| 43e5975 | Stephan Ewen | 01 March 2016, 13:31:26 UTC | [FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished This closes #1750 | 01 March 2016, 16:04:34 UTC |
| 8949ccf | Till Rohrmann | 01 March 2016, 11:36:22 UTC | [FLINK-3557] [stream, scala] Introduce secondary parameter list for fold function The fold API call takes an initial value as well as a fold function. In Scala it is possible to provide an anonymous function. In order to easily support multi line anonymous functions as well as being consistent with Scala's collection API, this PR adds another parameter list to the fold API call, which contains the fold function parameter. Insert spaces between first parameter list and curly braces of anonymous function This closes #1748. | 01 March 2016, 15:23:03 UTC |
| 2d56081 | Ufuk Celebi | 01 March 2016, 13:58:01 UTC | [FLINK-3559] [dist] Don't print INFO if no active process This closes #1751. | 01 March 2016, 14:32:53 UTC |
| 6262a0e | Ufuk Celebi | 01 March 2016, 11:23:31 UTC | [FLINK-3556] [runtime] Remove false check in HA blob store configuration This closes #1749. | 01 March 2016, 14:11:17 UTC |
| 8e30f86 | vasia | 29 February 2016, 21:49:35 UTC | [docs] fix readme typos; use the same scala style in the examples This closes #1743 | 01 March 2016, 10:49:14 UTC |
