- 09 12月, 2015 6 次提交
-
-
由 Maximilian Michels 提交于
This closes #1441.
-
由 Maximilian Michels 提交于
- This solves errors with reflectasm using Scala 2.11 and Java 8 This closes #1445.
-
由 Romeo Kienzler 提交于
This closes #1443.
-
由 Aljoscha Krettek 提交于
Before, streaming mode (either batch or streaming) would specify how memory is allocated on task managers. This introduces a new configuration value taskmanager.memory.allocation that can take values "lazy" or "eager". This controls how memory is allocated.
-
由 Aljoscha Krettek 提交于
-
由 Robert Metzger 提交于
This closes #1437
-
- 08 12月, 2015 5 次提交
-
-
由 twalthr 提交于
This closes #1440
-
由 Fabian Hueske 提交于
This closes #1435
-
由 Fabian Hueske 提交于
This closes #1436
-
由 Stephan Ewen 提交于
-
由 Greg Hogan 提交于
This closes #1292
-
- 07 12月, 2015 6 次提交
-
-
由 Robert Metzger 提交于
-
由 Sachin Goel 提交于
[FLINK-2488] [FLINK-2524] [FLINK-3124] Expose Attempt Number in RuntimeContext and add TaskInfo to hold all task related parameters. This closes #1386
-
由 Omer Katz 提交于
This closes #1366
-
由 Jun Aoki 提交于
This closes #1430 It seems AbstractJobVertex class no longer exists but the doc's link still points to it.
-
由 Jun Aoki 提交于
This closes #1438
-
由 Stephan Ewen 提交于
-
- 06 12月, 2015 2 次提交
-
-
由 Ufuk Celebi 提交于
Added Time.of(Time), because there is no TumblingTimeWindows.of(int, TimeUnit).
-
由 Ufuk Celebi 提交于
New users sometimes struggle with the imports (especially for Scala API).
-
- 05 12月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
This closes #1409
-
- 04 12月, 2015 1 次提交
-
-
由 chengxiang li 提交于
This closes #1431.
-
- 03 12月, 2015 3 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
-
- 02 12月, 2015 6 次提交
-
-
由 zentol 提交于
This closes #1383
-
由 Aljoscha Krettek 提交于
This also adds a test for asynchronous state handles.
-
由 Aljoscha Krettek 提交于
Before, it would not allow unioning with predecessors (also transitive) and streams of differing parallelism.
-
由 chengxiang li 提交于
-
由 Maximilian Michels 提交于
- refactor to use Storm's topology builder - remove FlinkTopologyBuilder - instantiate context-based StreamExecutionEnvironment (local or remote) - remove some of the Flink and Storm behavior replicating classes - modify FlinkTopology to parse Storm topology directly - replace StormTestBase with StreamingTestBase - add print example - FlinkTopologyBuilder changes (check if all inputs are available before processing) - correct package typo - two input support - add join example - update docs This closes #1398.
-
由 chengxiang li 提交于
-
- 01 12月, 2015 10 次提交
-
-
由 Maximilian Michels 提交于
The RabbitMQ source may operate in three different modes: 1) Exactly-once (when checkpointed) with RabbitMQ transactions and messages with unique correlation IDs. 2) At-least-once (when checkpointed) with RabbitMQ transactions but no deduplication mechanism (correlation id is not set). 3) No strong delivery guarantees (without checkpointing) with RabbitMQ auto-commit mode. - add base class which can handle both session ids and unique ids - session ids are used for acknowledgment - unique ids are used for de-duplication - add unit test - add documentation This closes #1243.
-
由 Hilmi Yildirim 提交于
-
由 Till Rohrmann 提交于
-
由 madhukar 提交于
This closes #1424.
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
This closes #1423
-
由 Fabian Hueske 提交于
This closes #1331
-
由 Chiwan Park 提交于
- Remove unnecessary indentation of table - Fix wrong `strong` end tag - Simplify lambda expression in map operation This closes #1312
-
由 Sachin Goel 提交于
Bytes are now displayed in the following fashion: 1. For [0, 1000) units, display three significant digits. 2. For [1000,1024) units, display 2 decimal points for the next higher unit. For example, 1010 KB is displayed as 0.99 MB, 10 MB is displayed as 10.0 MB and 230 MB is displayed as such. This closes #1419
-
由 zentol 提交于
This closes #1420
-