- 29 10月, 2015 10 次提交
-
-
由 Sachin Goel 提交于
This closes #1296
-
由 Sachin Goel 提交于
This closes #1307
-
由 Hubert Czerpak 提交于
- Remove broken HTML tags like <br/>, <p/>, ... - close unclosed HTML tags - replaces special chars by HTML escaping, e.g., '<' by < - wrap code examples by {@code} - fix incorrect @see and @link references - fix incorrect @throws - fix typos This closes #1298
-
由 Frederick F. Kautz IV 提交于
This closes #1309
-
由 Fabian Hueske 提交于
This closes #1293
-
由 gallenvara 提交于
This closes #1302
-
由 gallenvara 提交于
This closes #1270.
-
由 Till Rohrmann 提交于
The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This Output class is flushed by Flink's KryoSerializer upon finishing its serialize call. However, in case of an exception when flushing the Output, the buffered data is kept in the buffer. Since Flink uses EOFExceptions to mark that an underlying buffer is full and has to be spilled, for example, it can happen that the record triggering the spilling is written twice after it is rewritten. The reason is that Kryo's Output buffer still contains the serialization data of the failed attempt which is also flushed to the emptied output stream. This duplication of records can lead to corrupted data which eventually let's the Flink program crash. The problem is solved by clearing Kryo's Output when the flush operation was not successful. This closes #1308
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
Otherwise the javadoc fails to generate..
-
- 28 10月, 2015 4 次提交
-
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
[FLINK-2927] [runtime] Provide default required configuration keys in flink-conf of binary distribution This closes #1303.
-
由 Ufuk Celebi 提交于
This closes #1301.
-
- 27 10月, 2015 7 次提交
-
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
-
由 Saumitra Shahapure 提交于
This closes #1276
-
由 gallenvara 提交于
This closes #1300
-
由 gallenvara 提交于
This closes #1267
-
由 gallenvara 提交于
[FLINK-2889] Port LongSerializationSpeedBenchmark to JMH. This closes #1284 This closes #1283
-
- 26 10月, 2015 4 次提交
-
-
由 Martin Junghanns 提交于
* implemented algorithm * implemented integration tests * updated gelly guide This closes #1269
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 tedyu 提交于
This closes #1282
-
- 24 10月, 2015 2 次提交
-
-
由 mjsax 提交于
This closes #1274
-
由 Maximilian Michels 提交于
-
- 23 10月, 2015 13 次提交
-
-
由 Aljoscha Krettek 提交于
This enhances the TriggerResult enum with methods isFire() and isPurge() that simplify the logic in WindowOperator.processTriggerResult(). Also, the operator now keeps track of the current watermark and fires immediately if a trigger registers an event-time callback for a timestamp that lies in the past. For this the TriggerResult now as method merge() that allows to merge to TriggerResultS.
-
由 Aljoscha Krettek 提交于
Before these trigger methods had no information about the window that they are responsible for. This information might be required for implementing more advanced trigger behaviour.
-
由 Aljoscha Krettek 提交于
This fixes the aggregators to make copies of the objects so that it works with window operators that are not mutable-object safe. This also disables object copy in WindowOperator and NonKeyedWindowOperator.
-
由 Aljoscha Krettek 提交于
Before, the StreamRecords was not copied, now it is.
-
由 Aljoscha Krettek 提交于
-
由 Greg Hogan 提交于
Operators defer object creation when object reuse is disabled. This closes #1288
-
由 Greg Hogan 提交于
This closes #1290
-
由 Ufuk Celebi 提交于
Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper' Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir' Move ZooKeeper file system state backend configuration keys This closes #1286
-
由 Fabian Hueske 提交于
Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
0.10-SNAPSHOT continues on branch release-0.10
-
由 Aljoscha Krettek 提交于
Before it would only trigger if expectedTime < time. Now it is expectedTime <= time.
-
由 Fabian Hueske 提交于
-