[1/2] flink git commit: [FLINK-5933] Allow Evictor for merging windows

2017-05-04 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master c969237fc -> 99fb1f881 [FLINK-5933] Allow Evictor for merging windows Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/99fb1f88 Tree: http://git-wip-us.apache.org/repos/

[2/2] flink git commit: [hotfix] Add check for aligned assigner in AllWindowedStream.evictor()

2017-05-04 Thread aljoscha
[hotfix] Add check for aligned assigner in AllWindowedStream.evictor() This check is present in WindowedStream but was missing on AllWindowedStream. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a470046 Tree: http://git-wi

[2/7] flink git commit: [hotfix] [py] Code cleanup - Functions

2017-05-04 Thread chesnay
[hotfix] [py] Code cleanup - Functions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36950629 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36950629 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/36950629

[7/7] flink git commit: [FLINK-6177] Add support for "Distributed Cache" in streaming applications

2017-05-04 Thread chesnay
[FLINK-6177] Add support for "Distributed Cache" in streaming applications This closes #3741. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3655dee5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3655dee5 Diff: htt

[5/7] flink git commit: [FLINK-6367] support custom header settings of allow origin

2017-05-04 Thread chesnay
[FLINK-6367] support custom header settings of allow origin This closes #3769. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/127f1df6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/127f1df6 Diff: http://git-wip-us.

[1/7] flink git commit: [hotfix] [py] Improve error reporting in Python*InputStreamer

2017-05-04 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 99fb1f881 -> a2ec3ee66 [hotfix] [py] Improve error reporting in Python*InputStreamer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2ec3ee6 Tree: http://git-wip-us.ap

[4/7] flink git commit: [FLINK-6274] Replaces usages of org.codehaus.jackson

2017-05-04 Thread chesnay
[FLINK-6274] Replaces usages of org.codehaus.jackson This closes #3780. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6aa5bad7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6aa5bad7 Diff: http://git-wip-us.apache.

[3/7] flink git commit: [FLINK-3709] Prevent caching of outdated suspended ExecutionGraphs

2017-05-04 Thread chesnay
[FLINK-3709] Prevent caching of outdated suspended ExecutionGraphs This closes #3709. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49d0e432 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/49d0e432 Diff: http://git-

[6/7] flink git commit: [hotfix] [py] Code cleanup - SerializationUtils

2017-05-04 Thread chesnay
[hotfix] [py] Code cleanup - SerializationUtils Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/154bb3bb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/154bb3bb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/

flink git commit: [FLINK-6445] [cep] Fix NPE in no-condition patterns.

2017-05-04 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master a2ec3ee66 -> d6435e87c [FLINK-6445] [cep] Fix NPE in no-condition patterns. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d6435e87 Tree: http://git-wip-us.apache.org/

[2/2] flink git commit: [FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL.

2017-05-04 Thread fhueske
[FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL. This closes #3809. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/981dea41 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/981dea41 Diff: htt

[1/2] flink git commit: [FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL.

2017-05-04 Thread fhueske
Repository: flink Updated Branches: refs/heads/master d6435e87c -> 981dea41e http://git-wip-us.apache.org/repos/asf/flink/blob/981dea41/flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/utils/UserDefinedAggFunctions.java --