buildbot exception in on flink-docs-release-1.0

2016-06-08 Thread buildbot
The Buildbot has detected a build exception on builder flink-docs-release-1.0 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.0/builds/107 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

flink git commit: [FLINK-4031] include sources in Maven snapshot deployment

2016-06-08 Thread mxm
Repository: flink Updated Branches: refs/heads/master 297d75c2e -> fce64e193 [FLINK-4031] include sources in Maven snapshot deployment This closes #2082 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fce64e19 Tree:

[5/6] flink git commit: [FLINK-3922] [core] Fix case of infinite recursion in TypeExtractor

2016-06-08 Thread sewen
[FLINK-3922] [core] Fix case of infinite recursion in TypeExtractor This closes #2011 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1b55f03 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1b55f03 Diff:

[2/6] flink git commit: [hotfix] [nifi] Minor style cleanups in NiFi source

2016-06-08 Thread sewen
[hotfix] [nifi] Minor style cleanups in NiFi source Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b08b64ab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b08b64ab Diff:

[6/6] flink git commit: [FLINK-3405] [nifi] Extend NiFiSource with interface StoppableFunction

2016-06-08 Thread sewen
[FLINK-3405] [nifi] Extend NiFiSource with interface StoppableFunction This closes #2047 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38362c40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38362c40 Diff:

[1/6] flink git commit: [FLINK-2832] [tests] Hardens RandomSamplerTest

2016-06-08 Thread sewen
Repository: flink Updated Branches: refs/heads/master 65ee28c34 -> 297d75c2e [FLINK-2832] [tests] Hardens RandomSamplerTest Increase the level of significance from p=0.01 to p=0.001 and add retry annotations to random sampler tests. This should decrease the probability of failing random

[3/6] flink git commit: [FLINK-4000] [RabbitMQ] Fix for checkpoint state restore at MessageAcknowledgingSourceBase

2016-06-08 Thread sewen
[FLINK-4000] [RabbitMQ] Fix for checkpoint state restore at MessageAcknowledgingSourceBase As says documentation for MessageAcknowledgingSourceBase.restoreState() This method is invoked when a function is executed as part of a recovery run. Note that restoreState() is called before open(). So

[4/6] flink git commit: [FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase

2016-06-08 Thread sewen
[FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6afb2b00 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6afb2b00 Diff:

flink git commit: [FLINK-4011] Keep UserCodeClassLoader in archived ExecutionGraphs

2016-06-08 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master ea64921f8 -> 65ee28c34 [FLINK-4011] Keep UserCodeClassLoader in archived ExecutionGraphs This closes #2065 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65ee28c3

flink git commit: [FLINK-4025] RMQ Streaming: Possibility to customize queue

2016-06-08 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 1bbc1fb4d -> ea64921f8 [FLINK-4025] RMQ Streaming: Possibility to customize queue This patch adds the possibilty for th user of the RabbitMQ Streaming Connector to customize the queue which is used. There are use-cases in which you want to