[1/2] flink git commit: [FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas

2016-03-30 Thread uce
Repository: flink Updated Branches: refs/heads/master f08b7c913 -> bdf55b90d [FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas The TypeExtractor.getUnaryOperatorReturnType and TypeExtractor.getBinaryOperatorReturnType methods have been extended to support pos

[1/2] flink git commit: [FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas

2016-03-30 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.0 ce448cdbd -> dae29b425 [FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas The TypeExtractor.getUnaryOperatorReturnType and TypeExtractor.getBinaryOperatorReturnType methods have been extended to suppor

[2/2] flink git commit: [FLINK-3682] [cep] Assign processing timestamp in CEP operators

2016-03-30 Thread uce
[FLINK-3682] [cep] Assign processing timestamp in CEP operators This PR fixes the problem that the CEP operators did not assign the wall clock time as the timestamp to incoming in StreamRecords if the TimeCharacteristic was set to ProcessingTime. Processing element with a Long.MIN_VALUE timestam

[2/2] flink git commit: [FLINK-3682] [cep] Assign processing timestamp in CEP operators

2016-03-30 Thread uce
[FLINK-3682] [cep] Assign processing timestamp in CEP operators This PR fixes the problem that the CEP operators did not assign the wall clock time as the timestamp to incoming in StreamRecords if the TimeCharacteristic was set to ProcessingTime. Processing element with a Long.MIN_VALUE timestam

flink git commit: [tools] Update copy files function in release script

2016-03-30 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.0 245f0d8fc -> ce448cdbd [tools] Update copy files function in release script - people.apache.org has moved to home.apache.org - rsync currently not supported Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://gi

flink git commit: [hotfix] [cep] Add sanity check for erroneously pruned elements

2016-03-30 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-1.0 20890295b -> 245f0d8fc [hotfix] [cep] Add sanity check for erroneously pruned elements Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/245f0d8f Tree: http://git-wi

flink git commit: [hotfix] [cep] Add sanity check for erroneously pruned elements

2016-03-30 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 580a1778c -> f08b7c913 [hotfix] [cep] Add sanity check for erroneously pruned elements Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f08b7c91 Tree: http://git-wip-us.

[flink] Git Push Summary [forced push!] [Forced Update!]

2016-03-30 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.0 a3520931c -> 20890295b (forced update)

flink git commit: [FLINK-3636] Add ThrottledIterator to WindowJoin jar

2016-03-30 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.0 20890295b -> a3520931c [FLINK-3636] Add ThrottledIterator to WindowJoin jar Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3520931 Tree: http://git-wip-us.apache