[flink] branch master updated: [FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner (#8010)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 475a88c [FLINK-11946][table-planner-blink

[flink] branch master updated: [FLINK-11871][table-runtime-blink] Introduce LongHybridHashTable to improve performance when join key fits in long

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 299747f [FLINK-11871][table-runtime-blink

[flink] branch master updated: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg (#7961)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c02eec9 [FLINK-11882][table-runtime-blink

[flink] branch master updated: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 (#7981)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c6878ac [FLINK-11905][table-runtime-blink] Fix

[flink] branch master updated: [FLINK-11881][table-planner-blink] Introduce code generated typed sorter to blink table (#7958)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new e20a9f8 [FLINK-11881][table-planner-blink

[flink] branch master updated: [FLINK-11863][table-runtime-blink] Introduce channel to read and write compressed data (#7944)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3ed490f [FLINK-11863][table-runtime-blink

[flink] branch master updated: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime.

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 2345bbe [FLINK-11858][table-runtime-blink

[flink] branch master updated: [FLINK-11834] [table-planner-blink] Introduce flink logical relational nodes (#7910)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new fd04309 [FLINK-11834] [table-planner-blink

[flink] branch master updated: [FLINK-11827][table-runtime-blink] Introduce DataFormatConverters to convert between internal data format and java format

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new e2579e3 [FLINK-11827][table-runtime-blink

[flink] branch master updated: [FLINK-11803][table-planner-blink] Improve FlinkTypeFactory for Blink (#7898)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new fb256d4 [FLINK-11803][table-planner-blink

[flink] branch master updated: [hotfix] Fix typo in some API comments (#7867)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c6f3dbc [hotfix] Fix typo in some API comments

[flink] branch master updated: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 76eb039 [FLINK-11802][table-runtime-blink] Create

[flink] branch master updated: [FLINK-11795][table-planner-blink] Introduce DataStream nodes and converter rules for batch and stream

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 6918d62 [FLINK-11795][table-planner-blink

[flink] branch master updated: [FLINK-11790][table-planner-blink] Introduce FlinkRelNode interface and FlinkConventions

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new e3248d8 [FLINK-11790][table-planner-blink

[flink] branch master updated: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 76f979b [FLINK-11701][table-runtime-blink

[flink] branch master updated: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases.

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 2328ff3 [FLINK-11715][table-planner-blink] Add

[flink] branch master updated: [FLINK-11724][core] Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment.

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 492d1d4 [FLINK-11724][core] Add copyToUnsafe

[flink] branch master updated: [FLINK-11702][table-planner-blink] Introduce a new blink table type system: InternalType.

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 6070817 [FLINK-11702][table-planner-blink

[flink] branch master updated: [FLINK-11714][table-planner-blink] Add cost model for both batch and streaming

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 0ce0609 [FLINK-11714][table-planner-blink] Add

[flink] branch master updated: Fix typo in StreamExecutionEnvironment (#7854)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new cb3ffca Fix typo in StreamExecutionEnvironment

[flink] branch master updated: Fix typo in TypeInformation

This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 55a5504 Fix typo in TypeInformation 55a5504

[flink] branch blink created (now 185d730)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch blink in repository https://gitbox.apache.org/repos/asf/flink.git. at 185d730 blink first commit This branch includes the following new commits: new 185d730 blink first commit

[flink] branch blink deleted (was 1984fa1)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch blink in repository https://gitbox.apache.org/repos/asf/flink.git. was 1984fa1 blink first commit This change permanently discards the following revisions: discard 1984fa1 blink first

[flink] branch blink created (now 1984fa1)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch blink in repository https://gitbox.apache.org/repos/asf/flink.git. at 1984fa1 blink first commit This branch includes the following new commits: new 1984fa1 blink first commit

[flink] branch blink deleted (was c841076)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch blink in repository https://gitbox.apache.org/repos/asf/flink.git. was c841076 [FLINK-11354][tests] Port JobManagerHARecoveryTest to new code base The revisions that were on this branch

[flink] branch blink created (now c841076)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch blink in repository https://gitbox.apache.org/repos/asf/flink.git. at c841076 [FLINK-11354][tests] Port JobManagerHARecoveryTest to new code base No new revisions were added

flink git commit: [FLINK-6733] Remove commented out AvgAggregationFunction.java

31 17:38:31 2017 +0300 Committer: Kurt Young <k...@apache.org> Committed: Wed Sep 20 09:21:12 2017 +0800 -- .../aggregation/AvgAggregationFunction.java | 211 --- 1 file changed

flink git commit: [FLINK-7617] [runtime] Remove string format in BitSet to improve the performance of BuildSideOuterjoin

js3620...@aliyun.com> Authored: Thu Sep 14 14:42:34 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Fri Sep 15 09:05:44 2017 +0800 -- .../java/org/apache/flink/runtime/operators/util/BitSet.java | 6 ++

flink git commit: [FLINK-7617] [runtime] Remove string format in BitSet to improve the performance of BuildSideOuterjoin

js3620...@aliyun.com> Authored: Thu Sep 14 14:42:34 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Thu Sep 14 21:18:25 2017 +0800 -- .../java/org/apache/flink/runtime/operators/util/BitSet.java | 6 ++ 1

flink git commit: [FLINK-7161] Fix misusage of Float.MIN_VALUE and Double.MIN_VALUE

mit: 9bfc927eae9a14ecade64f213d97692a1ea29d35 Parents: 40b8f1b Author: Kurt Young <ykt...@gmail.com> Authored: Wed Jul 12 14:02:58 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Thu Jul 13 18:12:22 2017 +0800 -- .../flin

flink git commit: [FLINK-6394] [runtime] Respect object reuse configuration when executing group combining function

wip-us.apache.org/repos/asf/flink/commit/a820f662 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a820f662 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a820f662 Branch: refs/heads/release-1.2 Commit: a820f662d20d35915f21ab6bf0be4004e79b8c6b Parents: 52b6e2f Author: Kurt Young &

flink git commit: [FLINK-6394] [runtime] Respect object reuse configuration when executing group combining function

wip-us.apache.org/repos/asf/flink/commit/9c85ed23 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9c85ed23 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9c85ed23 Branch: refs/heads/release-1.3 Commit: 9c85ed23323cb75f347f44937c48253a76c49d4b Parents: a35664a Author: Kurt Young &

flink git commit: [FLINK-6394] [runtime] Respect object reuse configuration when executing group combining function

org/repos/asf/flink/commit/f5471bdc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f5471bdc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f5471bdc Branch: refs/heads/master Commit: f5471bdcb005ec5065c8c718a4758a0a77ac83bc Parents: a49ab6c Author: Kurt Young <ykt...@gma

flink git commit: [FLINK-6398] RowSerializer's duplicate should always return a new instance

ink/commit/c0fb70f1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c0fb70f1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c0fb70f1 Branch: refs/heads/release-1.2 Commit: c0fb70f1c46fda6736943cd836884be72d29781b Parents: ef20aa1 Author: Kurt Young <ykt...@gmail.com> Authored: T

flink git commit: [FLINK-6398] RowSerializer's duplicate should always return a new instance

mit/b0cd48dd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b0cd48dd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b0cd48dd Branch: refs/heads/master Commit: b0cd48dd31975aac88b4da32f31b14500b89edae Parents: 8ef6926 Author: Kurt Young <ykt...@gmail.com> Authored: Thu Apr 27

[2/2] flink-web git commit: Rebuild website

Branch: refs/heads/asf-site Commit: b1878e3330687f6c0f98ea8d36cbb5d0af188dcc Parents: afcedbb Author: Kurt Young <k...@apache.org> Authored: Tue Apr 25 17:48:54 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Tue Apr 25 17:48:5

[1/2] flink-web git commit: Add Kurt Young to committer list

Repository: flink-web Updated Branches: refs/heads/asf-site c2a77b5c4 -> b1878e333 Add Kurt Young to committer list Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/afcedbbf Tree: http://git-wip-us.apache.org/re

flink git commit: [FLINK-6327] [table] Bug in CommonCalc's estimateRowCount() method

3:25 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Thu Apr 20 09:00:00 2017 +0800 -- .../main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala | 2 +- 1 file changed, 1 insertion

[3/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

://git-wip-us.apache.org/repos/asf/flink/tree/6a0ada81 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6a0ada81 Branch: refs/heads/master Commit: 6a0ada81e19a972b89556f1b4b0277508b7caa7a Parents: 2ef4900 Author: Kurt Young <ykt...@gmail.com> Authored: Wed Mar 22 16:42:20 2017 +0800 Com

[2/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

http://git-wip-us.apache.org/repos/asf/flink/blob/6a0ada81/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalOverWindow.scala -- diff --git

[1/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

Repository: flink Updated Branches: refs/heads/master 2ef4900aa -> 6a0ada81e http://git-wip-us.apache.org/repos/asf/flink/blob/6a0ada81/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala

flink git commit: [FLINK-6068] [table] Support If() as a built-in function.

7:33 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Sat Mar 18 22:07:32 2017 +0800 -- .../scala/org/apache/flink/table/validate/FunctionCatalog.scala | 1 + .../apache/flink/table/expressions/ScalarOperatorsTe

flink git commit: [FLINK-5568] [table] Introduce ExternalCatalog interface, integrated with calcite and provide an in-memory implementation for testing.

hor: jingzhang <beyond1...@126.com> Authored: Fri Mar 17 20:51:37 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Sat Mar 18 21:37:04 2017 +0800 -- flink-libraries/flink-table/pom.xml | 20

[3/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2)

http://git-wip-us.apache.org/repos/asf/flink/blob/78f22aae/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/ProjectableTableSource.scala -- diff --git

[4/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2)

/repos/asf/flink/diff/78f22aae Branch: refs/heads/master Commit: 78f22aaec9bd7d39fdec8477335e5c9247d42030 Parents: 9f6cd2e Author: Kurt Young <ykt...@gmail.com> Authored: Mon Mar 13 15:30:13 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Fri Mar 17 18:01:5

[1/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1)

Repository: flink Updated Branches: refs/heads/master ab014ef94 -> 78f22aaec http://git-wip-us.apache.org/repos/asf/flink/blob/9f6cd2e7/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/util/RexProgramExpressionExtractorTest.scala

[2/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1)

11 13:15:49 2017 +0400 Committer: Kurt Young <k...@apache.org> Committed: Fri Mar 17 18:01:27 2017 +0800 -- .../flink/table/api/BatchTableEnvironment.scala | 2 +- .../table/api/StreamTableEnvironment.scala | 2 +

flink git commit: [FLINK-6040] [table] DataStreamUserDefinedFunctionITCase occasionally fails

: Tue Mar 14 18:08:14 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Wed Mar 15 09:13:03 2017 +0800 -- .../DataStreamUserDefinedFunctionITCase.scala | 36 ++-- 1 file changed, 11 insertions(+

flink git commit: [FLINK-6023] fix process function doc examples

2:55 2017 +0100 Committer: Kurt Young <k...@apache.org> Committed: Sat Mar 11 10:31:38 2017 +0800 -- docs/dev/stream/process_function.md | 56 1 file changed, 28 insertions(+

<    1   2   3   4