flink git commit: [FLINK-5624] [table] Add SQL support for tumbling windows on streaming tables.

2017-02-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master f24514339 -> 8304f3e15 [FLINK-5624] [table] Add SQL support for tumbling windows on streaming tables. This closes #3252. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly

2017-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master 494edb041 -> f24514339 [FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly This closes #3257 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5811] [tests] Harden YarnClusterDescriptorTest

2017-02-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 413609d13 -> 494edb041 [FLINK-5811] [tests] Harden YarnClusterDescriptorTest Add fail call after method which is supposed to fail. Remove stack trace printing to stdout. This closes #3326. Project:

flink git commit: [FLINK-5773] Use akka.actor.Status.Failure class to send failures via AskSupport

2017-02-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-1.2 d3f2fe262 -> a2853ec15 [FLINK-5773] Use akka.actor.Status.Failure class to send failures via AskSupport Akka's AskSupport trait requires that failures are wrapped in a akka.actor.Status.Failure to be recognized. Internally the trait

flink git commit: [FLINK-5773] Use akka.actor.Status.Failure class to send failures via AskSupport

2017-02-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 2ec2abfae -> 413609d13 [FLINK-5773] Use akka.actor.Status.Failure class to send failures via AskSupport Akka's AskSupport trait requires that failures are wrapped in a akka.actor.Status.Failure to be recognized. Internally the trait will

[2/6] flink git commit: [FLINK-5805] [docs] Improvements to docs for ProcessFunction

2017-02-16 Thread sewen
[FLINK-5805] [docs] Improvements to docs for ProcessFunction This closes #3317 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8fd374c9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8fd374c9 Diff:

[4/6] flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase

2017-02-16 Thread sewen
[hotfix] [tests] Stabilize FastFailuresITCase The test triggers 200 immediate failures and recoveries. The restart strategy allowed 200 restarts. It may happen that another failure occurs as during the execution, in which case the restart attempts are not sufficient. Project:

[5/6] flink git commit: [FLINK-5814] [build] Fix packaging flink-dist in unclean source directory

2017-02-16 Thread sewen
[FLINK-5814] [build] Fix packaging flink-dist in unclean source directory If "/build-target" already existed, running 'mvn package' for flink-dist would create a symbolic link inside "/build-target" instead of replacing that symlink. This commit fixes this behaviour of 'ln -sf' by adding the

[3/6] flink git commit: [hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator

2017-02-16 Thread sewen
[hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8837c0c5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8837c0c5 Diff:

[1/6] flink git commit: [FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per operator

2017-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.2 e9ada34f2 -> d3f2fe262 [FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per operator Previously, the factory was created once per checkpoint, and its repeated initialization logic (like ensuring existence of base

[6/6] flink git commit: [FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly

2017-02-16 Thread sewen
[FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly This closes #3257 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3f2fe26 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3f2fe26 Diff:

flink git commit: [FLINK-5814] [build] Fix packaging flink-dist in unclean source directory

2017-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master f250d95b7 -> 2ec2abfae [FLINK-5814] [build] Fix packaging flink-dist in unclean source directory If "/build-target" already existed, running 'mvn package' for flink-dist would create a symbolic link inside "/build-target" instead of

flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase

2017-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master 67e3d9d44 -> f250d95b7 [hotfix] [tests] Stabilize FastFailuresITCase The test triggers 200 immediate failures and recoveries. The restart strategy allowed 200 restarts. It may happen that another failure occurs as during the execution,

flink git commit: [FLINK-5751] [docs] Fix some broken links

2017-02-16 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 3b4f6cf8c -> e9ada34f2 [FLINK-5751] [docs] Fix some broken links Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9ada34f Tree:

flink git commit: [FLINK-5751] [docs] Fix some broken links

2017-02-16 Thread uce
Repository: flink Updated Branches: refs/heads/master ae0fbff76 -> 67e3d9d44 [FLINK-5751] [docs] Fix some broken links This closes #3329. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67e3d9d4 Tree:

flink-web git commit: Rebuild website

2017-02-16 Thread jark
Repository: flink-web Updated Branches: refs/heads/asf-site b321ee165 -> 2764a5116 Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/2764a511 Tree: