[06/16] flink git commit: Move operator ITCases into correct package

Move operator ITCases into correct package Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8543dd90 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8543dd90 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8543d

[11/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/PointInFormat.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans

[05/16] flink git commit: Remove ITCases for Record API operators

Remove ITCases for Record API operators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50ced5e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50ced5e3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50ced5e3

[09/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/util/InfiniteIntegerInputFormatWithDelay.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/re

[13/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

[FLINK-2901] Remove Record API dependencies from flink-tests #2 This closes #1306 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebba20df Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebba20df Diff: http://git-wip-

[12/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/g

[14/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #1

http://git-wip-us.apache.org/repos/asf/flink/blob/8abae2c2/flink-tests/src/test/java/org/apache/flink/test/testPrograms/util/tests/TupleTest.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/testPrograms/util/te

[03/16] flink git commit: Remove Record API program tests

Remove Record API program tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f84f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f84f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f84f Branch

[16/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #1

[FLINK-2901] Remove Record API dependencies from flink-tests #1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8abae2c2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8abae2c2 Diff: http://git-wip-us.apache.org/repos

[08/16] flink git commit: Remove Record API dependencies from CC iteration tests

Remove Record API dependencies from CC iteration tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b640c017 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b640c017 Diff: http://git-wip-us.apache.org/repos/asf/flin

[07/16] flink git commit: Remove Record API dependencies from WordCount compiler test

Remove Record API dependencies from WordCount compiler test Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d353ef49 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d353ef49 Diff: http://git-wip-us.apache.org/repos/asf

[10/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relati

[5/8] flink git commit: [FLINK-2906] Remove Record API

[FLINK-2906] Remove Record API This closes #1403 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c787a037 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c787a037 Diff: http://git-wip-us.apache.org/repos/asf/flink/dif

[6/8] flink git commit: [FLINK-3059] Improve JavaDocs for DataSet.writeAsText()

[FLINK-3059] Improve JavaDocs for DataSet.writeAsText() Currently the JavaDocs of writeAsText() state it simply generates a file, but this is not always true and it depends on the environment configuration. This commit improves the JavaDocs of writeAsText(). This closes #1392 Project: http://gi

[3/8] flink git commit: [FLINK-2906] Remove Record API

http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/main/java/org/apache/flink/api/java/record/operators/DeltaIteration.java -- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/record/operators

[2/8] flink git commit: [FLINK-2906] Remove Record API

http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/test/java/org/apache/flink/api/java/record/ReduceWrappingFunctionTest.java -- diff --git a/flink-java/src/test/java/org/apache/flink/api/java/record/ReduceW

[1/8] flink git commit: [FLINK-2906] Remove Record API

Repository: flink Updated Branches: refs/heads/master 8fddbf06c -> dcce6def9 http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-test-utils/src/main/java/org/apache/flink/test/util/RecordAPITestBase.java -- diff --

[8/8] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcce6def Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dcce6def Diff: http://git-wip-us.apach

[7/8] flink git commit: [typo-fix] Fix typo in DelimitedInputFormat.java

[typo-fix] Fix typo in DelimitedInputFormat.java This closes #1405 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/804611ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/804611ce Diff: http://git-wip-us.apache.org/r

[4/8] flink git commit: [FLINK-2906] Remove Record API

http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/main/java/org/apache/flink/api/java/record/io/DelimitedOutputFormat.java -- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/record/io/Delimi

[2/2] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16e5ab09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16e5ab09 Diff: http://git-wip-us.apach

[1/2] flink git commit: [docs] Fix typos in streaming documentation

Repository: flink Updated Branches: refs/heads/release-0.10 0b6adc4c5 -> 16e5ab09f [docs] Fix typos in streaming documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efbfc6ae Tree: http://git-wip-us.apache.org/rep

flink git commit: [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.

Repository: flink Updated Branches: refs/heads/master d5a6b13ab -> cd899f3be [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java. This closes #1331 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd899f3b Tree:

[1/4] flink-web git commit: Add blog post 'Introducing Stream Windows in Apache Flink'

"Introducing Stream Windows in Apache Flink" +date: 2015-12-04 10:00:00 +author: "Fabian Hueske" +author-twitter: "fhueske" +excerpt: "The data analysis space is witnessing an evolution from batch to stream processing for many use cases. Although batch can be handl

[3/4] flink-web git commit: rebuild website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/0507169a/content/blog/page2/index.html -- diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html index 445f2be..3d3cfaa 100644 --- a/content/blog/page2/index

[2/4] flink-web git commit: rebuild website

cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";> Wiki + + + + + + + + + + + + + + + + Introducing Stream Windows in Apache Flink + + +04 Dec 2015 by Fabian Hueske (https://twitter.co

[4/4] flink-web git commit: rebuild website

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/0507169a Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0507169a Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0507169a Branch

[1/3] flink git commit: [FLINK-3112] Remove unused RecordModelPostPass and replace JavaPlan by Plan.

Repository: flink Updated Branches: refs/heads/master 0cae3eae2 -> 4dbb10f52 [FLINK-3112] Remove unused RecordModelPostPass and replace JavaPlan by Plan. This closes #1436 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d

[2/3] flink git commit: [FLINK-3113] Remove unused and unsupported global-order methods from GenericDataSinkBase

[FLINK-3113] Remove unused and unsupported global-order methods from GenericDataSinkBase This closes #1435 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9547f08a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9547

[3/3] flink git commit: [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method

[FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method This closes #1440 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4dbb10f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4dbb10f5 Diff:

flink git commit: [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method

Repository: flink Updated Branches: refs/heads/release-0.10 a36822100 -> 9268514b7 [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9268514b Tre

[3/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java -- diff --git a/flink-core/src/main/java/org/apache/flink/ap

[5/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-core

[FLINK-3367] Add PublicEvolving and Internal annotations 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/53f8d773 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/53f8d773 Diff: http://git-wip-us.apache.or

[1/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala

Repository: flink Updated Branches: refs/heads/master 937963e33 -> c9db63b93 http://git-wip-us.apache.org/repos/asf/flink/blob/e5f33b6d/flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleRightUnwrappingJoiner.java --

[8/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala

[FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala This closes #1606 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9db63b9 Tree: http://git-wip-us.apache.org/repos/a

[6/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala

http://git-wip-us.apache.org/repos/asf/flink/blob/c9db63b9/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/Triggerable.java -- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/stream

[2/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala

[FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e5f33b6d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e5f33b6d Diff: http://git

[7/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala

http://git-wip-us.apache.org/repos/asf/flink/blob/c9db63b9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java -- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/strea

[4/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/operators/b

[2/2] flink git commit: [FLINK-3226] Translation of explicit casting

[FLINK-3226] Translation of explicit casting Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c53c873 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c53c873 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1c5

[1/2] flink git commit: [FLINK-3226] Casting support for arithmetic operators

Repository: flink Updated Branches: refs/heads/tableOnCalcite 7233c241d -> 1c53c873a [FLINK-3226] Casting support for arithmetic operators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d765d08 Tree: http://git-wip-us.ap

[1/2] flink git commit: [hotfix] [runtime] Fix processing unmatched build-side when all buckets spilled

Repository: flink Updated Branches: refs/heads/master 8656ed5ea -> 1c48e3462 [hotfix] [runtime] Fix processing unmatched build-side when all buckets spilled Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03923c34 Tree: ht

[2/2] flink git commit: [FLINK-3385] [runtime] Fix outer join skipping unprobed partitions

[FLINK-3385] [runtime] Fix outer join skipping unprobed partitions This closes #1680 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c48e346 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c48e346 Diff: http://git-w

flink git commit: [FLINK-3490] Bump Chill version to 0.7.4

Repository: flink Updated Branches: refs/heads/master 4e35d2cf2 -> cec7fbbc7 [FLINK-3490] Bump Chill version to 0.7.4 This closes #1701 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cec7fbbc Tree: http://git-wip-us.apac

flink git commit: [FLINK-3502] Add test case. Bug was resolved by a previous commit.

Repository: flink Updated Branches: refs/heads/tableOnCalcite 4a63e2914 -> e097cf7db [FLINK-3502] Add test case. Bug was resolved by a previous commit. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e097cf7d Tree: http://

[1/2] flink git commit: [FLINK-3486] [tableAPI] Fix broken renaming of all fields.

Repository: flink Updated Branches: refs/heads/tableOnCalcite 031d6f745 -> d940c3663 [FLINK-3486] [tableAPI] Fix broken renaming of all fields. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fe9357f Tree: http://git-wip-

[2/2] flink git commit: [FLINK-3498] Implement TRIM, SUBSTRING as reference design for Table API

[FLINK-3498] Implement TRIM, SUBSTRING as reference design for Table API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d940c366 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d940c366 Diff: http://git-wip-us.apache.

flink git commit: [FLINK-3593][tableAPI] Fix failing DistinctITCase

Repository: flink Updated Branches: refs/heads/tableOnCalcite e9b9b6f3a -> e34e43954 [FLINK-3593][tableAPI] Fix failing DistinctITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e34e4395 Tree: http://git-wip-us.apache

[2/3] flink git commit: [FLINK-3596] DataSet RelNode refactoring

[FLINK-3596] DataSet RelNode refactoring - remove the intermediate flink relnode layer and the dataset rules - move code generation from rules to DataSet nodes - remove unused DataSete nodes - move code generation from join rule to DataSetJoin node - merge DataSetMap and DataSetReduce into DataSe

[3/3] flink git commit: [FLINK-3596] Finalized DataSet RelNode refactoring

[FLINK-3596] Finalized DataSet RelNode refactoring Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d720b002 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d720b002 Diff: http://git-wip-us.apache.org/repos/asf/flink/di

[1/3] flink git commit: [FLINK-3596] DataSet RelNode refactoring

Repository: flink Updated Branches: refs/heads/tableOnCalcite e34e43954 -> d720b002a http://git-wip-us.apache.org/repos/asf/flink/blob/22621e02/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala ---

flink git commit: [FLINK-3333] [docs] Improve documentation of DataSet object-reuse modes.

Repository: flink Updated Branches: refs/heads/master 48151b1a7 -> 09d1fc427 [FLINK-] [docs] Improve documentation of DataSet object-reuse modes. This closes #1721 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09d1f

flink git commit: [FLINK-3333] [docs] Improve documentation of DataSet object-reuse modes.

Repository: flink Updated Branches: refs/heads/release-1.0 3d8c7c1ea -> 165065c3e [FLINK-] [docs] Improve documentation of DataSet object-reuse modes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/165065c3 Tree: http

flink git commit: [FLINK-3621] [docs] Improve documentation of memory configuration parameters

Repository: flink Updated Branches: refs/heads/release-1.0 165065c3e -> 6749874dc [FLINK-3621] [docs] Improve documentation of memory configuration parameters This closes #1801 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/com

flink git commit: [FLINK-3621] [docs] Improve documentation of memory configuration parameters

Repository: flink Updated Branches: refs/heads/master 543c04949 -> 40d5205bc [FLINK-3621] [docs] Improve documentation of memory configuration parameters This closes #1801 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/tableOnCalcite [deleted] 9dfed3427

[3/4] flink git commit: [FLINK-3631] [tableAPI] Check type compatibility for comparison expressions in CodeGenerator

[FLINK-3631] [tableAPI] Check type compatibility for comparison expressions in CodeGenerator This closes #1823 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22d327f0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/

[2/4] flink git commit: [FLINK-3602] Fix TypeExtractor and add support for recursive types

[FLINK-3602] Fix TypeExtractor and add support for recursive types This closes #1787 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7785288a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7785288a Diff: http://git-w

[4/4] flink git commit: [FLINK-3611] [docs] Correct link in CONTRIBUTING.md

[FLINK-3611] [docs] Correct link in CONTRIBUTING.md This closes #1786 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77c867a6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77c867a6 Diff: http://git-wip-us.apache.or

[1/4] flink git commit: [FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator

Repository: flink Updated Branches: refs/heads/master 9c8747d38 -> 76da44283 [FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator This closes #1822 This closes #1553 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: htt

[1/2] flink git commit: [FLINK-3602] Fix TypeExtractor and add support for recursive types

Repository: flink Updated Branches: refs/heads/release-1.0 954cdc113 -> cd5773ed3 [FLINK-3602] Fix TypeExtractor and add support for recursive types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0880c594 Tree: http://git

[2/2] flink git commit: [FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator

[FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd5773ed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd57

[1/4] flink git commit: [FLINK-2445] Improve HadoopOutputFormatTests

Repository: flink Updated Branches: refs/heads/master f7a3c8104 -> b8299bf92 [FLINK-2445] Improve HadoopOutputFormatTests This closes #1628 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bcb34dd5 Tree: http://git-wip-us.

[3/4] flink git commit: [FLINK-2444] Add tests for HadoopInputFormats

[FLINK-2444] Add tests for HadoopInputFormats This closes #1628 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6c3778f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6c3778f Diff: http://git-wip-us.apache.org/repo

[2/4] flink git commit: [FLINK-2445] Add tests for HadoopOutputFormats

[FLINK-2445] Add tests for HadoopOutputFormats This closes #1486 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e4a001b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8e4a001b Diff: http://git-wip-us.apache.org/rep

[4/4] flink git commit: [FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution.

[FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution. This closes #1776 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8299bf9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b829

[2/3] flink git commit: [FLINK-2445] Improve HadoopOutputFormatTests

[FLINK-2445] Improve HadoopOutputFormatTests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da989c42 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da989c42 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/da9

[3/3] flink git commit: [FLINK-2444] Add tests for HadoopInputFormats

[FLINK-2444] Add tests for HadoopInputFormats Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ca4f36d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1ca4f36d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1c

[1/3] flink git commit: [FLINK-2445] Add tests for HadoopOutputFormats

Repository: flink Updated Branches: refs/heads/release-1.0 1909bdb41 -> 1ca4f36d0 [FLINK-2445] Add tests for HadoopOutputFormats Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/edf343ab Tree: http://git-wip-us.apache.org/r

flink git commit: [FLINK-3736] [tableAPI] Move toRexNode logic into each expression's implementation.

Repository: flink Updated Branches: refs/heads/master 427de663c -> ba46ab6b6 [FLINK-3736] [tableAPI] Move toRexNode logic into each expression's implementation. This closes #1870 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

[06/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/CastingITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/

[04/12] flink git commit: [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs

[FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs Java 8 update 11 introduced a stricter bytecode verifier that leads to failures in unit tests that use the PowerMock runner. The tests run correctly in Java 8u51 or above. This closes #1882 Project: http://git-wip-us.ap

[07/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/TableEnvironmentITCase.java -- diff --git a/flink-libraries/flink-table/src/test/java/org/ap

[12/12] flink git commit: [FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode.

[FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode. This closes #1892 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/722155a1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/722155a

[10/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

[FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext. - Removes Translators (JavaBatchTranslator, ScalaBatchTranslator, JavaStreamTranslator, ScalaStreamTranslator) - Removes TranslationContext - Creates TableEnvironments for Java/Scala DataSet/DataStream AP

[03/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

[FLINK-3700] [core] Remove Guava dependency from flink-core Almost all Guava functionality used within flink-core has corresponding utils in Flink's codebase, or the JDK library. This replaces the Guava code as follows - Preconditions calls by Flink's Preconditions class - Collection utils by

[05/12] flink git commit: [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

[FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals() This closes #1871 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f3d3a449 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f3d3a449 Diff: ht

[09/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/TableConversions.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fl

[11/12] flink git commit: [FLINK-3762] [core] Enable Kryo reference tracking

[FLINK-3762] [core] Enable Kryo reference tracking This closes #1891 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc78a747 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc78a747 Diff: http://git-wip-us.apache.org

[02/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/760a0d9e/flink-core/src/main/java/org/apache/flink/types/StringValue.java -- diff --git a/flink-core/src/main/java/org/apache/flink/types/StringValue.java b/flink-core/src/main/jav

[01/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

Repository: flink Updated Branches: refs/heads/master 1b93b3242 -> d938c5f59 http://git-wip-us.apache.org/repos/asf/flink/blob/760a0d9e/flink-runtime/src/test/java/org/apache/flink/runtime/util/MathUtilTest.java -- diff --git

[08/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/AsITCase.java -- diff --git a/flink-libraries/flink-table/src/test/java/org/apache/flink/api

[2/3] flink git commit: [FLINK-3762] [core] Enable Kryo reference tracking

[FLINK-3762] [core] Enable Kryo reference tracking Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b4b08ca2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b4b08ca2 Diff: http://git-wip-us.apache.org/repos/asf/flink/di

[3/3] flink git commit: [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs

[FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs Java 8 update 11 introduced a stricter bytecode verifier that leads to failures in unit tests that use the PowerMock runner. The tests run correctly in Java 8u51 or above. Project: http://git-wip-us.apache.org/repos/asf/

[1/3] flink git commit: [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

Repository: flink Updated Branches: refs/heads/release-1.0 aadc5fad5 -> c1eb247e9 [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b69dd8c Tree:

flink git commit: [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public'

Repository: flink Updated Branches: refs/heads/master d938c5f59 -> 5f993c65e [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public' This closes #1829 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

[1/3] flink git commit: [FLINK-3665] [dataSet] Add support for sort orders in range partitioning.

Repository: flink Updated Branches: refs/heads/master c33325e3f -> a43bade0d [FLINK-3665] [dataSet] Add support for sort orders in range partitioning. This closes #1848 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8fb

[3/3] flink git commit: [FLINK-3781] Ensure BlobClient is closed.

[FLINK-3781] Ensure BlobClient is closed. This closes #1908 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a43bade0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a43bade0 Diff: http://git-wip-us.apache.org/repos/as

[2/3] flink git commit: [FLINK-2998] [dataSet] Add support for explicit range partitioning for joins and coGroup.

[FLINK-2998] [dataSet] Add support for explicit range partitioning for joins and coGroup. This closes #1838 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/605b6d87 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/605

flink git commit: [hotfix] [tableAPI] Fix DataStreamScanRule, fix indention, improve class names.

Repository: flink Updated Branches: refs/heads/master 7498d3e35 -> 8305c1755 [hotfix] [tableAPI] Fix DataStreamScanRule, fix indention, improve class names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8305c175 Tree: ht

flink git commit: [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names.

Repository: flink Updated Branches: refs/heads/master 130a22d6c -> 80b09eaef [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80b09eae Tr

flink git commit: [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names.

Repository: flink Updated Branches: refs/heads/release-1.0 014a686ec -> 4a34f6f73 [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a34f6

flink git commit: [FLINK-2828] [tableAPI] Add TableSource interfaces for external tables.

Repository: flink Updated Branches: refs/heads/master 80b09eaef -> 4f5dbc2ed [FLINK-2828] [tableAPI] Add TableSource interfaces for external tables. - Add CsvTableSource as a reference implementation for TableSources. This closes #1939 Project: http://git-wip-us.apache.org/repos/asf/flink/r

flink git commit: [FLINK-2946] Add support for orderBy() to batch Table API and SQL.

Repository: flink Updated Branches: refs/heads/master c81151e4e -> a5ad7d913 [FLINK-2946] Add support for orderBy() to batch Table API and SQL. This closes #1926. Closed because CsvTableSource has been implemented. This closes #939. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[06/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/test/java/org/apache/flink/test/testdata/WordCountData.java -- diff --git a/flink-test-utils/src/test/java/org/apache/flink/test/testdata/WordCountDat

[09/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

[FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies. This closes #1915 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70978f56 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/70

[01/10] flink git commit: [FLINK-3691] [avro] Extend AvroInputFormat to support Avro GenericRecord

Repository: flink Updated Branches: refs/heads/master 8ec47f17b -> 5c4cb452f [FLINK-3691] [avro] Extend AvroInputFormat to support Avro GenericRecord This closes #1920 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c4cb

[05/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/test/scala/org/apache/flink/test/util/ForkableFlinkMiniCluster.scala -- diff --git a/flink-test-utils/src/test/scala/org/apache/flink/test/util/Forkab

[07/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/main/scala/org/apache/flink/test/util/ForkableFlinkMiniCluster.scala -- diff --git a/flink-test-utils/src/main/scala/org/apache/flink/test/util/Forkab

[10/10] flink git commit: [FLINK-1996] [tableApi] Add TableSink interface to emit tables to external storage.

[FLINK-1996] [tableApi] Add TableSink interface to emit tables to external storage. - Add a CsvTableSink This closes #1961 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/13bce315 Tree: http://git-wip-us.apache.org/repos/as

<    1   2   3   4   5   6   7   8   9   10   >