- 23 2月, 2016 7 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
Adds further log statements in order to improve debuggability of JobManagerHAJobGraphRecoveryITCase. Hope to help for debugging: - hpick://s3.amazonaws.com/archive.travis-ci.org/jobs/110095304/log.txt - https://s3.amazonaws.com/archive.travis-ci.org/jobs/110085371/log.txt
-
由 Robert Metzger 提交于
This closes #1692
-
由 Kostas Kloudas 提交于
This closes #1588
-
由 Greg Hogan 提交于
This closes #1680
-
由 Greg Hogan 提交于
-
由 Robert Metzger 提交于
This closes #1684
-
- 22 2月, 2016 2 次提交
-
-
由 Aljoscha Krettek 提交于
The StateDescriptor can be serializer asynchronously in case of asynchronous checkpoints. In that case two threads would try to concurrently use the TypeSerializer: The normal state updating and the checkpoint serialization. If the TypeSerializer is a KryoSerializer this can lead to problems. Therefore the need to duplicate it before using in "writeObject".
-
由 Aljoscha Krettek 提交于
-
- 21 2月, 2016 4 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
This adds more default constructor parameters to the RMQSource. In addition, users may override the setupConnectionFactory() method to return their onwn configured factory. This closes #1670.
-
由 Ufuk Celebi 提交于
This closes #1678.
-
- 20 2月, 2016 5 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Ufuk Celebi 提交于
This closes #1673.
-
由 Ufuk Celebi 提交于
Squashes the following commits: - [tests] Wait for task managers in JobManagerFailsITCase Possible fix for: https://s3.amazonaws.com/archive.travis-ci.org/jobs/110235128/log.txt - [tests] Move ITCase from runtime to tests - [tests] Merge abstract and sub type class - [tests] Determine JobManagerProcess ports from logs This closes #1676.
-
由 Ufuk Celebi 提交于
-
由 Robert Metzger 提交于
- Remove Guava dependency - Remove unused methods - Move ZKString Serializer - Add user-friendly error messages when parsing arguments This closes #1623 and closes #1672
-
- 19 2月, 2016 4 次提交
-
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
-
由 vasia 提交于
This closes #1663
-
- 18 2月, 2016 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 zentol 提交于
This closes #1653
-
由 zentol 提交于
This closes #1650
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
They are not specific to RocksDB, just utilities for copying local folders to/from HDFS. Moving them to flink-streaming-java means that they are always in the classpath of the TaskManager, not only in the user-code jar when using RocksDB. If they are only in the user-code jar the external process runner cannot find the class files, leading to ClassNotFoundExceptions.
-
- 17 2月, 2016 13 次提交
-
-
由 Aljoscha Krettek 提交于
This closes #1655
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-3413] [streaming] Make implicit conversions from Java DataStream to Scala DataStream explicit This also clean up a lot of JavaDocs in various Scala DataStream API classes.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
This closes #1642.
-
由 Stephan Ewen 提交于
[FLINK-3401] [streaming] [api breaking] AscendingTimestampExtractor only logs violations of ascending timestamp order. The user can also explicitly set an 'IgnoringHandler' or a 'FailingHandler', which do nothing on violations, respectively fail hard.
-
由 Stephan Ewen 提交于
- one class handled periodic watermarks - the other class handled watermarks triggered by elements This also makes sure that any timestamp assigner / watermark generators cannot generate negative watermarks This closes #1646
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-