[40/50] [abbrv] flink git commit: [FLINK-3489] TableAPI refactoring and cleanup

[FLINK-3489] TableAPI refactoring and cleanup This closes #1789 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63c6dad4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/63c6dad4 Diff: http://git-wip-us.apache.org/repo

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

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

[21/50] [abbrv] flink git commit: [FLINK-3537] Fix code gen for disjunctions.

[FLINK-3537] Fix code gen for disjunctions. This closes #1733 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad3a6366 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ad3a6366 Diff: http://git-wip-us.apache.org/repos/

[30/50] [abbrv] flink git commit: [FLINK-3474]: Enable partial aggregate in Table API -- add new Aggregate interface which support partial aggregate -- implement SUM/COUNT/AVG/MIN/MAX aggregate functi

[FLINK-3474]: Enable partial aggregate in Table API -- add new Aggregate interface which support partial aggregate -- implement SUM/COUNT/AVG/MIN/MAX aggregate functions implementation -- sorted-based runtime support this closes #1746 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Co

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

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

[34/50] [abbrv] flink git commit: [FLINK-3574] Implement math functions for Table API

[FLINK-3574] Implement math functions for Table API This closes #1775. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/316932c0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/316932c0 Diff: http://git-wip-us.apache.o

[32/50] [abbrv] flink git commit: [FLINK-3597][tableAPI] Set relational expressions as DataSet operator names.

[FLINK-3597][tableAPI] Set relational expressions as DataSet operator names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a779d5cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a779d5cb Diff: http://git-wip-us.apa

[25/50] [abbrv] flink git commit: [FLINK-3226] Improvements for expected types

[FLINK-3226] Improvements for expected types This closes #1709 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5d6a564 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5d6a564 Diff: http://git-wip-us.apache.org/repos

[15/50] [abbrv] flink git commit: [FLINK-3226] implement GroupReduce translation; enable tests for supported operations

http://git-wip-us.apache.org/repos/asf/flink/blob/7972426e/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apa

buildbot failure in on flink-docs-release-0.9

The Buildbot has detected a new failure on builder flink-docs-release-0.9 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.9/builds/269 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: The Nightly s

[29/50] [abbrv] flink git commit: [FLINK-3567] Fix selection on grouping. Only grouping keys or aggregates allowed.

[FLINK-3567] Fix selection on grouping. Only grouping keys or aggregates allowed. This closes #1761 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49699f04 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/49699f04 Di

[08/50] [abbrv] flink git commit: [FLINK-3282] add FlinkRelNode interface.

[FLINK-3282] add FlinkRelNode interface. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0611b9e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0611b9e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d0611b9

[04/50] [abbrv] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

[FLINK-3223] Translate Table API calls to Calcite RelNodes. This is an intermediate step to port the Table API on top of Calcite (FLINK-3221). This commit: - Adds Calcite as dependency to flink-table. - Translates Table API calls directly into Calcite RelNodes. - Modifies tests to check only the

buildbot success in on flink-docs-release-1.0

The Buildbot has detected a restored build on builder flink-docs-release-1.0 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.0/builds/16 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: The Nightly

[09/50] [abbrv] flink git commit: Renamed Table.scala to table.scala

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/71a7d20b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/71a7d20b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/71a7d20b Bra

[3/4] flink git commit: [hotfix][docs] fs.hdfs.hadoopconf typo

[hotfix][docs] fs.hdfs.hadoopconf typo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8dcfac7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d8dcfac7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d8dcfac7

[02/50] [abbrv] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

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

[27/50] [abbrv] flink git commit: [FLINK-3486] [tableAPI] Fix broken renaming of all fields.

[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/805e425c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/805e425c Diff: http://git-wip-us.apache.org/repos/asf/

[12/50] [abbrv] flink git commit: [FLINK-3508] Add more test cases to verify the rules of logical plan optimization.

[FLINK-3508] Add more test cases to verify the rules of logical plan optimization. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/10d3a311 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/10d3a311 Diff: http://git-wip

[01/50] [abbrv] flink git commit: [FLINK-3225] Enforce translation to DataSetNodes

Repository: flink Updated Branches: refs/heads/master 6968d07df -> 59d243791 [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/5388d7ba Tree: http://git-wip-us.apache.org/repo

[13/50] [abbrv] flink git commit: [FLINK-3226] Casting support for arithmetic operators

[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/f05f8fb4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f05f8fb4 Diff: http://git-wip-us.apache.org/repos/asf/flink

[flink] Git Push Summary

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

[48/50] [abbrv] flink git commit: [tableAPI] fix JoinITCase non-equality tests

[tableAPI] fix JoinITCase non-equality tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59d24379 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59d24379 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/59d

[33/50] [abbrv] flink git commit: [FLINK-3604][tableAPI] Enable and fix ignored tests.

[FLINK-3604][tableAPI] Enable and fix ignored tests. This closes #1782. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16460094 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16460094 Diff: http://git-wip-us.apache.

[43/50] [abbrv] flink git commit: [FLINK-3609] [tableAPI] Reorganize selection of optimization rules

[FLINK-3609] [tableAPI] Reorganize selection of optimization rules This closes #1797 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e430dee3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e430dee3 Diff: http://git-w

[28/50] [abbrv] 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/7afa755f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7afa755f Diff: http://git-wip-us.apache.

[45/50] [abbrv] flink git commit: [FLINK-3612] remove PageRank Table example

[FLINK-3612] remove PageRank Table example add a type conversion mapper after aggregations if the expected type is not a Row This closes #1793 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/074ea701 Tree: http://git-wip-us

[46/50] [abbrv] flink git commit: [tableAPI] Cleaned up tests

[tableAPI] Cleaned up tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29fb3d27 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29fb3d27 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/29fb3d27 Branch: re

[1/4] flink git commit: [FLINK-1964] Reimplement TwitterSource

Repository: flink Updated Branches: refs/heads/master 33f43114d -> edafb3e6c http://git-wip-us.apache.org/repos/asf/flink/blob/e70d49ec/flink-streaming-connectors/flink-connector-twitter/src/test/java/org/apache/flink/streaming/connectors/twitter/examples/TwitterFilterSourceExample.java ---

[20/50] [abbrv] flink git commit: [FLINK-3564] [table] Implement distinct() for Table API

[FLINK-3564] [table] Implement distinct() for Table API This closes #1754 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7cab28d6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7cab28d6 Diff: http://git-wip-us.apach

[49/50] [abbrv] flink git commit: [FLINK-3503] [tableAPI] Add cost model for DataSet RelNodes to improve plan selection.

[FLINK-3503] [tableAPI] Add cost model for DataSet RelNodes to improve plan selection. This closes #1798 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da4431df Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da4431

flink git commit: [FLINK-3629] Fix quick start description for the ".timeWindow()" function call

Repository: flink Updated Branches: refs/heads/master edafb3e6c -> f866de6ec [FLINK-3629] Fix quick start description for the ".timeWindow()" function call Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f866de6e Tree: htt

[11/50] [abbrv] 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/907a0957 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/907a0957 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/907

[3/3] flink git commit: [hotfix] [docs] Fix broken link for time.htm, changed to event_time.html

[hotfix] [docs] Fix broken link for time.htm, changed to event_time.html This closes #1816. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6968d07d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6968d07d Diff: http:

[2/3] flink git commit: [hotFix] [tableAPI] Improve naming of DataSetRelNodes

[hotFix] [tableAPI] Improve naming of DataSetRelNodes This closes #1799 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e666992 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1e666992 Diff: http://git-wip-us.apache.

[4/4] flink git commit: [hotfix][examples] Add zookeeper.connect to usage line

[hotfix][examples] Add zookeeper.connect to usage line Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/edafb3e6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/edafb3e6 Diff: http://git-wip-us.apache.org/repos/asf/flin

[41/50] [abbrv] flink git commit: [FLINK-3593][tableAPI] Fix failing DistinctITCase

[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/a5d8ae29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a5d8ae29 Diff: http://git-wip-us.apache.org/repos/asf/flink/dif

[47/50] [abbrv] flink git commit: [FLINK-3622] [tableAPI] Improve execeptions for invalid joins

[FLINK-3622] [tableAPI] Improve execeptions for invalid joins Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b76ffc5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3b76ffc5 Diff: http://git-wip-us.apache.org/repos/a

[24/50] [abbrv] flink git commit: [FLINK-3482] implement union translation - implement custom JoinUnionTransposeRules because Calcite's only match with LogicalUnion

[FLINK-3482] implement union translation - implement custom JoinUnionTransposeRules because Calcite's only match with LogicalUnion This closes #1715 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4f6b91ec Tree: http://git-wi

[14/50] [abbrv] flink git commit: [FLINK-3226] Translation from and to POJOs for CodeGenerator

[FLINK-3226] Translation from and to POJOs for CodeGenerator This closes #1624 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a46bfac Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a46bfac Diff: http://git-wip-us.

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

[3/3] flink git commit: [FLINK-3503] [tableAPI] Add cost model for DataSet RelNodes to improve plan selection.

[FLINK-3503] [tableAPI] Add cost model for DataSet RelNodes to improve plan selection. This closes #1798 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9dfed342 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9dfed3

[03/50] [abbrv] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

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

[39/50] [abbrv] flink git commit: [FLINK-3489] TableAPI refactoring and cleanup

http://git-wip-us.apache.org/repos/asf/flink/blob/63c6dad4/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RowComparator.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fl

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

[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/ab16e3c3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ab16e3c3 Diff: http://git-wip-us.apache.org/re

[19/50] [abbrv] flink git commit: [FLINK-3226] implement getUniqueName method in TranslationContext

[FLINK-3226] implement getUniqueName method in TranslationContext This closes #1600 and #1567 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/670ec6af Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/670ec6af Diff: htt

Jenkins build is back to normal : flink-snapshot-deployment #34

See

[1/3] flink git commit: [hotfix] [docs] Fix typo 'seperate'

Repository: flink Updated Branches: refs/heads/master f866de6ec -> 6968d07df [hotfix] [docs] Fix typo 'seperate' This closes #1810. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1071055 Tree: http://git-wip-us.apache.o

buildbot exception in on flink-docs-release-1.0

The Buildbot has detected a build exception on builder flink-docs-release-1.0 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.0/builds/15 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: The Nightl

[07/50] [abbrv] 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: http://git-wip-us.apache.org/rep

[22/50] [abbrv] flink git commit: [FLINK-3463] implement calc translation

[FLINK-3463] implement calc translation - remove FlinkFilter, FlinkProject and associated rules - deactivate FilterReduceExpressionsRule and ProjectReduceExpressionsRule (covered by CalcReduceExpressions) This closes #1696 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: ht

[16/50] [abbrv] flink git commit: [FLINK-3226] implement GroupReduce translation; enable tests for supported operations

[FLINK-3226] implement GroupReduce translation; enable tests for supported operations Squashes the following commits: - Compute average as sum and count for byte, short and int type to avoid rounding errors - Move aggregation functions to org.apache.flink.table.runtime - Remove join-related chan

[18/50] [abbrv] flink git commit: [FLINK-3226] Translate logical joins to physical

[FLINK-3226] Translate logical joins to physical This closes #1632 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f89d303e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f89d303e Diff: http://git-wip-us.apache.org/r

[50/50] [abbrv] flink git commit: [docs][tableAPI] update TableAPI docs

[docs][tableAPI] update TableAPI docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b9f1ff0d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b9f1ff0d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b9f1ff0d