[1/2] flink git commit: [FLINK-3247] Remove * exclude from quickstarts

Repository: flink Updated Branches: refs/heads/master 79058edb6 -> 360f02b1f [FLINK-3247] Remove * exclude from quickstarts This closes #1573 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/360f02b1 Tree:

[2/2] flink git commit: [FLINK-3287] Shade Curator dependency into flink-connector-kafka-0.8

[FLINK-3287] Shade Curator dependency into flink-connector-kafka-0.8 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb1a5ecb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb1a5ecb Diff:

flink-web git commit: [FLINK-3316] Fix broken links in first paragraph of landing page

Repository: flink-web Updated Branches: refs/heads/asf-site b68e1f48b -> ffe31bf53 [FLINK-3316] Fix broken links in first paragraph of landing page Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/ffe31bf5 Tree:

[13/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/TupleSerializerTestInstance.java -- diff --git

[01/38] flink git commit: [hotfix] Reduce the heavy sysout verbosity for certain tests

Repository: flink Updated Branches: refs/heads/master 360f02b1f -> 8fc7e7af2 [hotfix] Reduce the heavy sysout verbosity for certain tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f042e78 Tree:

[05/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/CompositeTypeTest.java -- diff --git

[30/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java

[08/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java -- diff --git

[23/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple15Builder.java -- diff --git

[04/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/AvroGenericTypeComparatorTest.java -- diff --git

[09/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java -- diff --git

[38/38] flink git commit: [FLINK-3314] [streaming] Fix case where early cancel messages do not properly cancel a stream operator.

[FLINK-3314] [streaming] Fix case where early cancel messages do not properly cancel a stream operator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8fc7e7af Tree:

[03/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/TupleComparatorISD1Test.java -- diff --git

[22/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

[FLINK-3303] [core] Move all type utilities to flink-core Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/21a71586 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/21a71586 Diff:

[29/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java

[33/38] flink git commit: [FLINK-3049] [api breaking] Move 'Either' type to 'flink-core / org.apache.flink.types'

[FLINK-3049] [api breaking] Move 'Either' type to 'flink-core / org.apache.flink.types' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54743866 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54743866 Diff:

[06/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/type/extractor/PojoTypeInformationTest.java -- diff --git

[26/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java -- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java

[36/38] flink git commit: [hotfix] Remove old sysout debug message in UdfAnalyzerTest

[hotfix] Remove old sysout debug message in UdfAnalyzerTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b90542e8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b90542e8 Diff:

[37/38] flink git commit: [hotfix] Fix warnings concerning joda-time in "flink-tests"

[hotfix] Fix warnings concerning joda-time in "flink-tests" Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c356ef33 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c356ef33 Diff:

[20/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeInfoParser.java -- diff --git

[18/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java -- diff --git

[10/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java -- diff --git

[14/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/PojoSubclassSerializerTest.java -- diff --git

[34/38] flink git commit: [FLINK-2348] Fix unstable IterateExampleITCase.

[FLINK-2348] Fix unstable IterateExampleITCase. This deactivates the validation of results, which is not reliably possible under the current model (timeout on feedback). This test for now only checks that the job executes properly. Also adds proper logging property files for the examples

[02/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoGenericTypeSerializerTest.java -- diff --git

[17/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/PojoTypeExtractionTest.java -- diff --git

[25/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java -- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java

[31/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java

[15/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/ValueTypeInfoTest.java -- diff --git

[11/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java -- diff --git

[12/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java -- diff --git

[35/38] flink git commit: [hotfix] [streaming] Various cleanups in StreamTask - Clean up generics - Clean and safe disposal of initialized resources - Add names to asynchronous materialization threads

[hotfix] [streaming] Various cleanups in StreamTask - Clean up generics - Clean and safe disposal of initialized resources - Add names to asynchronous materialization threads - Fix concurrent modification of materialization threads set Project:

[21/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfo.java -- diff --git

[19/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java -- diff --git

[32/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

[FLINK-3303] [core] Move Tuple classes to flink-core Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7081836e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7081836e Diff:

[07/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java -- diff --git

[28/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple15Builder.java -- diff --git

flink git commit: [FLINK-3175][Kafka 0.8] Relax test condition

Repository: flink Updated Branches: refs/heads/master f8677464b -> 682d8d5e2 [FLINK-3175][Kafka 0.8] Relax test condition Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/682d8d5e Tree:

[3/3] flink git commit: [FLINK-3216] [FLINK-3217] [cep] Adds CEP operator for pattern recognition

[FLINK-3216] [FLINK-3217] [cep] Adds CEP operator for pattern recognition Implements NFA using the SharedBuffer Implements NFACompiler to compile a Pattern into a NFA Add CEP operator Makes NFA and SharedBuffer serializable Add serializability support to SharedBuffer and NFA Add keyed cep

[2/3] flink git commit: [FLINK-3216] [FLINK-3217] [cep] Adds CEP operator for pattern recognition

http://git-wip-us.apache.org/repos/asf/flink/blob/79058edb/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java -- diff --git

[1/3] flink git commit: [FLINK-3216] [FLINK-3217] [cep] Adds CEP operator for pattern recognition

Repository: flink Updated Branches: refs/heads/master 682d8d5e2 -> 79058edb6 http://git-wip-us.apache.org/repos/asf/flink/blob/79058edb/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java -- diff --git