[3/6] flink git commit: [FLINK-1045][dataSet] Remove Combinable annotation.

http://git-wip-us.apache.org/repos/asf/flink/blob/5914e9ab/flink-tests/src/test/java/org/apache/flink/test/optimizer/examples/KMeansSingleStepTest.java -- diff --git

[2/6] flink git commit: [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

[FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys. - Unify usage of expression keys: FLINK-1666 - Unify supported key expressions (incl. support for partitioning on atomic types: FLINK-3233) - Remove removal of duplicate keys: FLINK-1903 - Unify checks for sort keys - Add more tests

[5/6] flink git commit: [FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping.

[FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping. This closes #1548 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/902d420e Tree:

[4/6] flink git commit: [FLINK-1045][dataSet] Remove Combinable annotation.

[FLINK-1045][dataSet] Remove Combinable annotation. This closes #1522 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5914e9ab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5914e9ab Diff:

[6/6] flink git commit: [FLINK-3289][docs] References to flink-contrib merged

[FLINK-3289][docs] References to flink-contrib merged This closes #1550 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e67a059 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1e67a059 Diff:

[1/6] flink git commit: [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

Repository: flink Updated Branches: refs/heads/master 984013607 -> 1e67a0596 http://git-wip-us.apache.org/repos/asf/flink/blob/af029e7e/flink-java/src/test/java/org/apache/flink/api/java/operators/ExpressionKeysTest.java --

flink git commit: Renamed Table.scala to table.scala

Repository: flink Updated Branches: refs/heads/tableOnCalcite e4ee0c6d7 -> d6f04a7e9 Renamed Table.scala to table.scala Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d6f04a7e Tree:

flink git commit: [FLINK-3225] Enforce translation to DataSetNodes

Repository: flink Updated Branches: refs/heads/tableOnCalcite 7ecb70105 -> 297564646 [FLINK-3225] Enforce translation to DataSetNodes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29756464 Tree:

[2/3] flink git commit: [FLINK-3161] [dist] Externalize cluster start-up and tear-down when available

[FLINK-3161] [dist] Externalize cluster start-up and tear-down when available Parallelizes cluster start-up and tear-down when pdsh is available This closes #1523 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7d19115

[3/3] flink git commit: [FLINK-3254] [dataSet] Adding functionality to support the CombineFunction contract.

[FLINK-3254] [dataSet] Adding functionality to support the CombineFunction contract. This closes #1568 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aabb2688 Tree:

[1/3] flink git commit: [FLINK-3293] [yarn] Respect custom CLI Yarn name in JobManager mode

Repository: flink Updated Branches: refs/heads/master 1198664cb -> aabb2688a [FLINK-3293] [yarn] Respect custom CLI Yarn name in JobManager mode Added a method to set a default application name for the Flink Yarn session CLI. Switched the order, such that this name can now be overwritten by

[1/3] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

Repository: flink Updated Branches: refs/heads/tableOnCalcite 364928e74 -> 7ecb70105 http://git-wip-us.apache.org/repos/asf/flink/blob/7ecb7010/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/SelectITCase.java

[3/3] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

[FLINK-3225] Implemented optimization of Table API queries via Calcite - added logical Flink nodes and translation rules - added stubs for DataSet translation rules - ported DataSetNodes to Scala - reactivated tests and added expected NotImplementedError Project:

[2/3] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

http://git-wip-us.apache.org/repos/asf/flink/blob/7ecb7010/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/operators/DataSetTable.scala -- diff --git

[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:

[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:

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:

[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

[3/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

http://git-wip-us.apache.org/repos/asf/flink/blob/e4ee0c6d/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/VerifyNoNestedAggregates.scala -- diff --git

[1/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

Repository: flink Updated Branches: refs/heads/tableOnCalcite a65cd8db1 -> e4ee0c6d7 http://git-wip-us.apache.org/repos/asf/flink/blob/e4ee0c6d/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/UnionITCase.scala

[2/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

http://git-wip-us.apache.org/repos/asf/flink/blob/e4ee0c6d/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/SelectITCase.java -- diff --git

[6/6] flink git commit: [FLINK-3285][maven] Skip deployment of flink-java8 module

[FLINK-3285][maven] Skip deployment of flink-java8 module This closes #1547 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4280e1f9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4280e1f9 Diff:

[1/6] flink git commit: [FLINK-3280] Change Boolean.getBoolean to Boolean.valueOf

Repository: flink Updated Branches: refs/heads/master 733847459 -> d39892624 [FLINK-3280] Change Boolean.getBoolean to Boolean.valueOf Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3989262 Tree:

[2/6] flink git commit: [FLINK-3209] Remove Unused ProcessingTime, EventTime and AbstractTime

[FLINK-3209] Remove Unused ProcessingTime, EventTime and AbstractTime Only keep Time for specifying time durations/intervals. This closes #1512 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf75f424 Tree:

[4/6] flink git commit: [hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code.

[hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code. This closes #1531 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ad1d5ed Tree:

[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:

[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:

[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

[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

[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:

[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

[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

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:

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:

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:

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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[flink] Git Push Summary

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

[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:

[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:

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:

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:

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:

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

[1/4] flink git commit: [hotfix] [tableAPI] Adapt tests to changed null-value support default

Repository: flink Updated Branches: refs/heads/master 09b428bd6 -> 996ad4e5b [hotfix] [tableAPI] Adapt tests to changed null-value support default Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/960f4acc Tree:

[3/4] flink git commit: [FLINK-3935] [optimizer] Fix check of key fields and ordering in PartitionNode.

[FLINK-3935] [optimizer] Fix check of key fields and ordering in PartitionNode. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/853a5359 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/853a5359 Diff:

[2/4] flink git commit: [FLINK-3934] [tableAPI] Check for equi-join predicates before translation.

[FLINK-3934] [tableAPI] Check for equi-join predicates before translation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3d6ce294 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3d6ce294 Diff:

[4/4] flink git commit: [FLINK-3632] [tableAPI] Clean up TableAPI exceptions.

[FLINK-3632] [tableAPI] Clean up TableAPI exceptions. This closes #2015 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9cc62966 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9cc62966 Diff:

[2/4] flink git commit: [hotfix] [tableAPI] Throw helpful exception for unsupported ORDER BY features.

[hotfix] [tableAPI] Throw helpful exception for unsupported ORDER BY features. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/905ac6ed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/905ac6ed Diff:

flink git commit: [hotfix] [tableAPI] Moved tests to correct package.

Repository: flink Updated Branches: refs/heads/master 885fbaf66 -> 343d05a40 [hotfix] [tableAPI] Moved tests to correct package. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/343d05a4 Tree:

[2/2] flink git commit: [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex()

[FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex() This closes #2004 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db5ff636 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db5ff636 Diff:

[1/3] flink git commit: [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex()

Repository: flink Updated Branches: refs/heads/master fd3dba6ee -> 09b428bd6 [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex() This closes #2004 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-3728] [tableAPI] Improve error message and documentation for unsupported SQL features.

[FLINK-3728] [tableAPI] Improve error message and documentation for unsupported SQL features. This closes #2018 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/78f55119 Tree:

[1/2] flink git commit: [FLINK-3955] [tableAPI] Rename Table.toSink() to Table.writeToSink().

Repository: flink Updated Branches: refs/heads/master 343d05a40 -> 78f551194 [FLINK-3955] [tableAPI] Rename Table.toSink() to Table.writeToSink(). This closes #2023 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/5] flink-web git commit: Rebuild website for Stream SQL blog post

t/news/2015/12/04/Introducing-windows.html @@ -160,7 +160,7 @@ 04 Dec 2015 by Fabian Hueske (https://twitter.com/fhueske;>@fhueske) -The data analysis space is witnessing an evolution from batch to stream processing for many use cases. Although batch can be handled as a spe

[3/5] flink-web git commit: Rebuild website for Stream SQL blog post

/blog/index.html @@ -161,6 +161,18 @@ + Stream Processing for Everyone with SQL and Apache Flink + 24 May 2016 by Fabian Hueske (https://twitter.com/fhueske;>@fhueske) + + About six months ago, the Apache Flink community started an effort to add a SQL interf

[1/5] flink-web git commit: Add Stream SQL blog post

he Flink" +date: 2016-05-24 10:00:00 +author: "Fabian Hueske" +author-twitter: "fhueske" +excerpt: "About six months ago, the Apache Flink community started an effort to add a SQL interface for stream data analysis. SQL is the standard language to access and

[3/4] flink git commit: [FLINK-3842] [tableApi] Fix handling null record/row in generated code

[FLINK-3842] [tableApi] Fix handling null record/row in generated code This closes #1974 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/08e80546 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/08e80546 Diff:

[1/4] flink git commit: [FLINK-3821] [dataSet] Remove Guava usage in flink-java non-test files.

Repository: flink Updated Branches: refs/heads/master 05c765e57 -> 43bd6f6e4 [FLINK-3821] [dataSet] Remove Guava usage in flink-java non-test files. - replaced CharSets with StandardCharsets - added checkElementIndex to Flink Preconditions - replaced Guava Preconditions with Flink

[2/4] flink git commit: [hotfix] [tableAPI] Fix SQL queries on TableSources.

[hotfix] [tableAPI] Fix SQL queries on TableSources. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ed07933 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ed07933 Diff:

[3/5] flink git commit: [FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes.

[FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes. This closes #1958 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0d543f8 Tree:

[4/5] flink git commit: [FLINK-3900] [tableAPI] Set nullCheck=true as default in TableConfig.

[FLINK-3900] [tableAPI] Set nullCheck=true as default in TableConfig. This closes #1994 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2e60575 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2e60575 Diff:

[2/5] flink git commit: [FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes.

http://git-wip-us.apache.org/repos/asf/flink/blob/f0d543f8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala -- diff --git

[5/5] flink git commit: [FLINK-3913] [docs] Clean up spelling mistakes.

[FLINK-3913] [docs] Clean up spelling mistakes. This closes #1992 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4fbd8eb9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4fbd8eb9 Diff:

flink git commit: [FLINK-3878] Fix support multiple identical temp directories in FileCache

Repository: flink Updated Branches: refs/heads/release-1.0 647525515 -> 4ae55cfd7 [FLINK-3878] Fix support multiple identical temp directories in FileCache This closes #1965 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-3878] Fix support multiple identical temp directories in FileCache

[FLINK-3878] Fix support multiple identical temp directories in FileCache This closes #1965 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c90d365 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c90d365 Diff:

[1/3] flink git commit: [FLINK-3856] [core] [api-extending] Create types for java.sql.Date/Time/Timestamp

Repository: flink Updated Branches: refs/heads/master 43bd6f6e4 -> 3c90d3654 [FLINK-3856] [core] [api-extending] Create types for java.sql.Date/Time/Timestamp This closes #1959 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3912] [docs] Fix errors in Batch Scala API Documentation, Join section

Repository: flink Updated Branches: refs/heads/master 96b353d98 -> a9fc71d85 [FLINK-3912] [docs] Fix errors in Batch Scala API Documentation, Join section This closes #1991 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[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

[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:

[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

[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:

[02/10] flink git commit: [FLINK-3519] [core] Add warning about subclasses to Tuple JavaDocs.

[FLINK-3519] [core] Add warning about subclasses to Tuple JavaDocs. - Bring TupleGenerator up to date with the Tuple classes. This closes #1724 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f186446d Tree:

[03/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-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java -- diff --git

[04/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-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java -- diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java

[08/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/java/org/apache/flink/test/testdata/WordCountData.java -- diff --git

[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

[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:

[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

[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:

[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

[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

[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

[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

[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:

[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:

[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:

[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:

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