| 4afa401 | Ufuk Celebi | 31 March 2016, 13:40:33 UTC | Commit for release 1.0.1 | 31 March 2016, 13:40:33 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 |
| 3048690 | Aljoscha Krettek | 29 February 2016, 19:20:07 UTC | [FLINK-3548] [api-breaking] Remove unnecessary generic parameter from SingleOutputStreamOperator | 29 February 2016, 20:37:46 UTC |
| 74c62b0 | Robert Metzger | 29 February 2016, 15:13:02 UTC | [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency This closes #1737 | 29 February 2016, 20:11:24 UTC |
| ae5b457 | Aljoscha Krettek | 29 February 2016, 13:56:29 UTC | [FLINK-3536] Make clearer distinction between event time and processing time This brings it more in line with *ProcessingTimeWindows and makes it clear what type of window assigner it is. The old name, i.e. SlidingTimeWindows and TumblingTimeWindows is still available but deprecated. | 29 February 2016, 19:39:51 UTC |
| 9b9f84e | Aljoscha Krettek | 29 February 2016, 16:02:38 UTC | [FLINK-3538] [api-breaking] Streamline Scala DataStream.join/coGroup This enforces that the user always has to specify keys for both inputs before .window() can be called. | 29 February 2016, 19:27:56 UTC |
| 3adff87 | Ufuk Celebi | 29 February 2016, 13:14:35 UTC | [FLINK-3535] [runtime-web] Decrease log verbosity of StackTraceSampleCoordinator This closes #1732. | 29 February 2016, 19:10:18 UTC |
| 70ce072 | Ufuk Celebi | 29 February 2016, 14:37:45 UTC | [FLINK-3534] [runtime] Prevent canceling Execution from failing This closes #1735. | 29 February 2016, 19:06:50 UTC |
| 7026271 | Stephan Ewen | 29 February 2016, 15:24:47 UTC | [docs] Update readme with current feature list and streaming example | 29 February 2016, 15:32:12 UTC |
| 5b5136e | Till Rohrmann | 29 February 2016, 11:01:10 UTC | [FLINK-3532] [gelly] Fix artifact ID of flink-gelly-examples module The current flink-gelly-examples artifact id wrongly used an underscore to separate examples from flink-gelly. This commit replaces the underscore with an hyphen. This closes #1731. | 29 February 2016, 11:18:07 UTC |
| a94aa9c | Ufuk Celebi | 25 February 2016, 23:11:48 UTC | [FLINK-3517] [dist] Only count active PIDs in start script | 29 February 2016, 09:30:34 UTC |
| 945f25b | sahitya-pavurala | 24 February 2016, 02:08:23 UTC | [FLINK-3461] [runtime] Remove redundant check in ZooKeeperLeaderElectionService This closes #1700. | 29 February 2016, 09:18:28 UTC |
| eb16421 | Jark Wu | 28 February 2016, 03:02:33 UTC | [docs] fix typos in Basic Concepts documentation Closes #1730 | 28 February 2016, 14:43:48 UTC |
| 1e2a9b8 | Aljoscha Krettek | 26 February 2016, 19:56:40 UTC | [FLINK-3527] Add Scala DataStream.transform() This implicitly adds KeyedStream.transform() and also explicitly ConnectedStreams.transform(). This also removes the transform exclusions from the API completeness tests. | 26 February 2016, 23:39:59 UTC |
| 75e03ca | Aljoscha Krettek | 26 February 2016, 22:27:26 UTC | [FLINK-3528] Add FoldingWindowBuffer for Non-Keyed Windows This makes AllWindowedStream.fold() take constant space, just like the keyed WindowOperator. Also this adds a new test case in EventTimeAllWindowCheckpointingITCase to verify that the FoldingWindowBuffer works. This also renames the preexisting window buffers to ReducingWindowBuffer and ListWindowBuffer to make the naming scheme consistent. | 26 February 2016, 23:30:33 UTC |
| ba069f3 | Aljoscha Krettek | 26 February 2016, 14:19:50 UTC | [FLINK-3521] Make Iterable part of method signature for WindowFunction This closes #1723 | 26 February 2016, 23:10:52 UTC |
| 603f351 | Stephan Ewen | 26 February 2016, 19:06:06 UTC | [FLINK-3526] [streaming] Fix Processing Time Window Assigner and Trigger This closes #1727 | 26 February 2016, 20:12:27 UTC |
| c0ce1b6 | Till Rohrmann | 26 February 2016, 15:27:06 UTC | [FLINK-3511] [twitter] Move twitter examples to test scope This closes #1725 | 26 February 2016, 19:57:36 UTC |
| 0dc8240 | Till Rohrmann | 26 February 2016, 15:21:13 UTC | [FLINK-3511] [nifi, elasticsearch] Move nifi and elasticsearch examples to test scope | 26 February 2016, 19:57:36 UTC |
| 434cff0 | Till Rohrmann | 26 February 2016, 15:15:44 UTC | [FLINK-3511] [jdbc] Move jdbc examples to test scope and add flink-clients dependency | 26 February 2016, 19:57:21 UTC |
| 131f016 | Till Rohrmann | 26 February 2016, 15:12:59 UTC | [FLINK-3511] [hadoop-compatibility] Move hadoop-compatibility examples to test scope | 26 February 2016, 19:57:21 UTC |
| 0444792 | Till Rohrmann | 26 February 2016, 14:57:45 UTC | [FLINK-3511] [avro] Move avro examples to test scope | 26 February 2016, 19:57:04 UTC |
| 2c605d2 | Till Rohrmann | 26 February 2016, 13:08:02 UTC | [FLINK-3511] [gelly] Introduce flink-gelly-examples module The new flink-gelly-examples module contains all Java and Scala Gelly examples. The module contains compile scope dependencies on flink-java, flink-scala and flink-clients so that the examples can be conveniently run from within the IDE. | 26 February 2016, 19:57:04 UTC |
| c0bc8bc | Till Rohrmann | 26 February 2016, 10:57:21 UTC | [hotfix] [build] Disable exclusion rules when using build-jar maven profile. This closes #1719 | 26 February 2016, 19:57:04 UTC |
| 51ab77b | Stephan Ewen | 26 February 2016, 17:31:32 UTC | [license] Update LICENSE file for the latest version | 26 February 2016, 19:57:04 UTC |
| 0601a76 | Stephan Ewen | 26 February 2016, 14:34:06 UTC | [hotfix] Remove remaining unused files from the old standalone web client | 26 February 2016, 19:57:04 UTC |
| f2de20b | Stephan Ewen | 26 February 2016, 17:19:27 UTC | [FLINK-3525] [runtime] Fix call to super.close() in TimestampsAndPeriodicWatermarksOperator | 26 February 2016, 19:57:04 UTC |
| 8c33015 | Stephan Ewen | 26 February 2016, 14:12:07 UTC | [FLINK-3522] [storm compat] PrintSampleStream prints a proper message when involked without arguments | 26 February 2016, 19:56:24 UTC |
| f3c6646 | Stephan Ewen | 22 February 2016, 17:37:59 UTC | [hotfix] Make DataStream property methods properly Scalaesk This also includes some minor cleanups This closes #1689 | 26 February 2016, 19:56:24 UTC |
| df19a8b | Ufuk Celebi | 26 February 2016, 11:46:07 UTC | [FLINK-3390] [runtime, tests] Restore savepoint path on ExecutionGraph restart Temporary work around to restore initial state on failure during recovery as required by a user. Will be superseded by FLINK-3397 with better handling of checkpoint and savepoint restoring. A failure during recovery resulted in restarting a job without its savepoint state. This temporary work around makes sure that if the savepoint coordinator ever restored a savepoint and there was no checkpoint after the savepoint, the savepoint state will be restored again. This closes #1720. | 26 February 2016, 19:56:24 UTC |
| 016644a | vasia | 25 February 2016, 16:36:37 UTC | [hotfix] fix PageRank example to run with no args; some doc fixes This closes #1714 | 26 February 2016, 13:21:46 UTC |
| 677425e | Stefano Baghino | 26 February 2016, 08:52:49 UTC | [FLINK-3518] Stale docs for quickstart setup * Explicitly state to stop the local environment This closes #1718 | 26 February 2016, 13:21:46 UTC |
| 2d64ca2 | Robert Metzger | 26 February 2016, 12:56:33 UTC | [hotfix][deploy script] Deploy 'release-*' branches as well | 26 February 2016, 12:57:11 UTC |
| de9a878 | Stephan Ewen | 26 February 2016, 11:01:44 UTC | [FLINK-3520] [streaming] Periodic watermark operator emits current watermark in close() This makes sure that for bounded data sets with watermarks, the final elements get properly reflected in window results. | 26 February 2016, 12:32:27 UTC |
| 725f746 | zentol | 19 February 2016, 12:39:19 UTC | [FLINK-3449] createInput() no longer swallows exception This closes #1675 | 26 February 2016, 10:37:59 UTC |
| 0fb6e0d | zentol | 18 February 2016, 12:35:39 UTC | [FLINK-3434] Prevent NPE in ClientFrontend#getClient() This closes #1695 | 26 February 2016, 10:35:08 UTC |
| 9692c83 | Robert Metzger | 25 February 2016, 15:30:56 UTC | [FLINK-3509] Update Hadoop minor versions to latest & sync travis and release scripts This closes #1713 | 26 February 2016, 10:34:10 UTC |
| fa8b001 | Greg Hogan | 10 February 2016, 21:12:19 UTC | [FLINK-3340] [runtime] Fix object juggling in drivers A second attempt at object swapping in reduce drivers. This closes #1626 | 26 February 2016, 10:32:51 UTC |
| ee76fc4 | Greg Hogan | 17 February 2016, 16:52:22 UTC | [FLINK-3437] [web-dashboard] Fix UI router state for job plan Transitive dependency EvEmitter updated to 1.0.2 This closes #1661 | 26 February 2016, 10:32:00 UTC |
| db6fda6 | Maximilian Michels | 25 February 2016, 09:20:42 UTC | [FLINK-3485][core] implement toString for SerializedListAccumulator The change improves the display of SerializedListAccumulators in the web interface by displaying the number of elements contained in the accumulator instead of the hash code of the object. This closes #1717. | 26 February 2016, 09:22:35 UTC |
| 930a266 | Ufuk Celebi | 25 February 2016, 23:26:52 UTC | [FLINK-3510] [cep] Fix typo in Pattern class level comment | 25 February 2016, 23:28:14 UTC |
| c9cba27 | Ufuk Celebi | 25 February 2016, 15:55:38 UTC | [FLINK-3512] [runtime] Savepoint backend should not revert to 'jobmanager' This closes #1712. | 25 February 2016, 19:03:57 UTC |
| d90672f | Ufuk Celebi | 25 February 2016, 15:55:04 UTC | [FLINK-3513] [runtime] Fix interplay of automatic Operator UID and Changing name of WindowOperator | 25 February 2016, 19:03:50 UTC |
| a5ecb18 | Till Rohrmann | 25 February 2016, 16:26:46 UTC | [hotfix] [cep] Fix serialization problem and single state NFAs The start computation states have a null event associated. When serializing these states one has to check whether the event is null or not, because not all serializer can handle null values. A single state NFA failed to compute a matching pattern because it was regarded as a terminal state in the pattern extraction algorithm. By letting the first states start with a two level dewey number this problem is fixed. | 25 February 2016, 16:33:02 UTC |
| 56e660d | Robert Metzger | 25 February 2016, 13:36:51 UTC | [hotfix][build scripts] Ensure that the hadoop1 version is set properly everywhere | 25 February 2016, 14:59:57 UTC |
| e811e6e | Ufuk Celebi | 24 February 2016, 19:39:37 UTC | [FLINK-3500] [test] Fix possible instability in ExecutionGraphRestartTest After restart of the execution graph, the test driver waits for the graph to assign the new executions in a loop. If switchToRunning() is called multiple times in this loop, the job is canceled. This could happen, if one execution had its resource assigned and called switchToRunning(), but the other didn't. In this case, the complete loop was retried and switchToRunning() was called again. This closes #1708. | 24 February 2016, 23:05:41 UTC |
