- 01 7月, 2016 10 次提交
-
-
由 zentol 提交于
-
由 zentol 提交于
-formatting -don't use implicit conversions -fixed ObjectName for mapped bufferpool
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
This closes #2146
-
由 Aljoscha Krettek 提交于
-
由 Mao Wei 提交于
This closes #2179
-
由 Greg Hogan 提交于
This closes #2185
-
由 Greg Hogan 提交于
Rename MessageFunction to ScatterFunction and VertexUpdateFunction to GatherFunction. Change the parameter order in Graph.runScatterGatherIteration(VertexUpdateFunction, MessagingFunction) to Graph.runScatterGatherIteration(ScatterFunction, GatherFunction) This closes #2184
-
- 30 6月, 2016 4 次提交
-
-
由 Aljoscha Krettek 提交于
Before, when snapshotting, we printed a log message about the file input format not being checkpointable when the current split was "null". Now, we only print the message when when appropriate. This closes #2174
-
由 Aljoscha Krettek 提交于
@PowerMockIgnore({"javax.management.*", "com.sun.jndi.*"}) was changed to @PowerMockIgnore("javax.*"). This broke builds on Travis.
-
由 kl0u 提交于
-
由 Till Rohrmann 提交于
-
- 29 6月, 2016 8 次提交
-
-
由 zentol 提交于
-
由 Robert Metzger 提交于
This closes #2175
-
由 Gordon Tai 提交于
Includes: 1. Scala examples for consumer and producer 2. Add information about AWS Kinesis service usage 3. Add Kinesis connecter to the fault tolerance guarantees table 4. Minor typo fix in Kafka documentation This closes #2181
-
由 Gordon Tai 提交于
[FLINK-4080] Guarantee exactly-once for Kinesis consumer for failures in the middle of aggregated records This closes #2180
-
由 Till Rohrmann 提交于
The test case failed because it exceeded the deadline. Increasing the deadline and decreasing the number of reelection should harden the test case.
-
由 twalthr 提交于
This closes #2150.
-
由 Greg Hogan 提交于
This closes #1967
-
由 Greg Hogan 提交于
This closes #1671
-
- 28 6月, 2016 6 次提交
-
-
由 Till Rohrmann 提交于
-
由 Maximilian Michels 提交于
-
由 Till Rohrmann 提交于
-
由 Robert Metzger 提交于
This closes #2166
-
由 Greg Hogan 提交于
Guard test for ChainedAllReduceDriver This closes #2156.
-
由 Greg Hogan 提交于
This closes #2160
-
- 27 6月, 2016 12 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 kl0u 提交于
-
由 kl0u 提交于
-
由 kl0u 提交于
Introduces a custom TimeServiceProvider to the StreamTask. This is responsible for defining and updating the current processingtime for a task and handling all related action, such as registering timers for actions to be executed in the future.
-
由 Aljoscha Krettek 提交于
Before, a job would fail if object reuse was enabled and multiple operators were chained to one upstream operator. Now, we create shallow copies in BroadcastingOutputCollector and DirectedOutput if object reuse is enabled.
-
由 Till Rohrmann 提交于
This closes #2112
-
由 zentol 提交于
This closes #2134
-
由 zentol 提交于
This closes #2145
-
由 zentol 提交于
-
由 zentol 提交于
This closes #2105
-
由 Andrea Sella 提交于
This closes #2163
-
由 Robert Metzger 提交于
-