- 13 12月, 2015 1 次提交
-
-
由 Sachin Goel 提交于
This closes #1422
-
- 11 12月, 2015 2 次提交
-
-
由 Aljoscha Krettek 提交于
Kafka sources that don't read from any partition never emit a watermark, thereby blocking the progress of event-time in downstream operations. This changes the Kafka Source to emit a Long.MAX_VALUE watermark if it knows that it will never receive data. This also changes the Timestamp Extraction operator to reacto to a Long.MAX_VALUE watermark by itself emitting a Long.MAX_VALUE watermark.
-
由 Aljoscha Krettek 提交于
Before, would throw a ClassCastException when emitting watermarks with timestamp/watermark multiplexing disabled.
-
- 10 12月, 2015 2 次提交
-
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
This closes #1416
-
- 09 12月, 2015 7 次提交
-
-
由 mjsax 提交于
-
由 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 4 次提交
-
-
由 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.
-