flink git commit: [FLINK-7798] [table] Add support for stream time-windowed inner join to Table API

2017-10-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 861c57cb1 -> e79cedf23 [FLINK-7798] [table] Add support for stream time-windowed inner join to Table API This closes #4825. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

flink git commit: [FLINK-7371] [table] Add support for constant parameters in OVER aggregate

2017-10-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 404e37d21 -> 861c57cb1 [FLINK-7371] [table] Add support for constant parameters in OVER aggregate This closes #4736. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86

[2/2] flink git commit: [hotfix] Change WindowFunction to ProcessWindowFunction in window doc

2017-10-16 Thread aljoscha
[hotfix] Change WindowFunction to ProcessWindowFunction in window doc There were some places where the doc still referred to WindowFunction where ProcessWindowFunction should be used instead now. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

[1/2] flink git commit: [hotfix] Change order of reduce and fold in window documentation

2017-10-16 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 0214e8003 -> 404e37d21 [hotfix] Change order of reduce and fold in window documentation In the section about incremental aggregation with a window function the order of fold and reduce was different from the order of fold and reduce in the

flink git commit: [FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning

2017-10-16 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 3e333793c -> 0214e8003 [FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0214e800 Tree:

flink git commit: [FLINK-7810] Add more excludes in end-to-end tests

2017-10-16 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master f853f3359 -> 3e333793c [FLINK-7810] Add more excludes in end-to-end tests With the switch to Akka 2.4 this message can crop up in the logs, it's only a warning, though. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: ht

flink git commit: [FLINK-7763] [table] Fix testing RowSink for enabled object reuse.

2017-10-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.3 664a04c89 -> 80c23de70 [FLINK-7763] [table] Fix testing RowSink for enabled object reuse. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80c23de7 Tree: http://git

flink git commit: [FLINK-7140][blob] add an additional random component into the BlobKey

2017-10-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master b2b94632d -> f853f3359 [FLINK-7140][blob] add an additional random component into the BlobKey This should guard us from uploading (and deleting) the same file more than once and also from hash collisions. This closes #4359. Project: http