flink git commit: [FLINK-8833] [sql-client] Create a SQL Client JSON format fat-jar

2018-03-26 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 69d98a325 -> 337b4ef23 [FLINK-8833] [sql-client] Create a SQL Client JSON format fat-jar This closes #5700. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/337b4e

flink git commit: [hotfix] [sql-client] Add flink-sql-client as 'provided' to flink-dist

2018-03-26 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 1277e920d -> 86731eab2 [hotfix] [sql-client] Add flink-sql-client as 'provided' to flink-dist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86731eab Tree: http://git-

flink git commit: [hotfix] [sql-client] Add flink-sql-client as 'provided' to flink-dist

2018-03-26 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 337b4ef23 -> e2285ad50 [hotfix] [sql-client] Add flink-sql-client as 'provided' to flink-dist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e2285ad5 Tree: http:/

[2/2] flink git commit: [FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script.

2018-03-27 Thread twalthr
[FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c37b157 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c37b157 Diff: http://git-wip-us.apache.org

[1/2] flink git commit: [FLINK-9067] [e2eTests] Fix test and simplify code

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/master c28096a32 -> e04a3bf77 [FLINK-9067] [e2eTests] Fix test and simplify code This closes #5759. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e04a3bf7 Tree: http://git-

[1/2] flink git commit: [FLINK-9067] [e2eTests] Fix test and simplify code

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 871dccbdf -> c5fa87f69 [FLINK-9067] [e2eTests] Fix test and simplify code This closes #5759. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c5fa87f6 Tree: http:/

[2/2] flink git commit: [FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script.

2018-03-27 Thread twalthr
[FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11ca9fa4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/11ca9fa4 Diff: http://git-wip-us.apache.org

flink git commit: [hotfix] Fix wrong parent version

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 c5fa87f69 -> 8b4543bfd [hotfix] Fix wrong parent version Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b4543bf Tree: http://git-wip-us.apache.org/repos/asf/flin

[2/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
[FLINK-9093] [docs] Ship jQuery library without external provider This closes #5770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a61ea47 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3a61ea47 Diff: http://git-w

[1/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/master e04a3bf77 -> 3a61ea479 http://git-wip-us.apache.org/repos/asf/flink/blob/3a61ea47/docs/page/js/jquery.min.js -- diff --git a/docs/page/js/jquery.min.js b/docs/page/js/jquery

[1/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 8b4543bfd -> fb98e2a3b http://git-wip-us.apache.org/repos/asf/flink/blob/fb98e2a3/docs/page/js/jquery.min.js -- diff --git a/docs/page/js/jquery.min.js b/docs/page/js/j

[2/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
[FLINK-9093] [docs] Ship jQuery library without external provider This closes #5770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fb98e2a3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fb98e2a3 Diff: http://git-w

[2/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
[FLINK-9093] [docs] Ship jQuery library without external provider This closes #5770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e3b95a70 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e3b95a70 Diff: http://git-w

[1/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 8b1376b18 -> e3b95a70a http://git-wip-us.apache.org/repos/asf/flink/blob/e3b95a70/docs/page/js/jquery.min.js -- diff --git a/docs/page/js/jquery.min.js b/docs/page/js/j

[2/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
[FLINK-9093] [docs] Ship jQuery library without external provider This closes #5770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb50c20c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb50c20c Diff: http://git-w

[1/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.3 b6cfe7baa -> cb50c20c2 http://git-wip-us.apache.org/repos/asf/flink/blob/cb50c20c/docs/page/js/jquery.min.js -- diff --git a/docs/page/js/jquery.min.js b/docs/page/js/j

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

2018-03-27 Thread twalthr
.org/news/2017/12/21/2017-year-in-review.html /news/2017/12/21/2017-year-in-review.html @@ -963,7 +963,7 @@ lingjinjiang, mengji.fy, minwenjun, mtunique, p1tz, paul, rtudoran, shaoxuan-wan bretschneider, sunjincheng121, tedyu, twalthr, uybhatti, wangmiao1981, yew1eb, z00376786, zentol, zhangmin

[4/5] flink-web git commit: Rebuild website

2018-03-27 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink-web/blob/d37cedd8/content/js/jquery.min.js -- diff --git a/content/js/jquery.min.js b/content/js/jquery.min.js new file mode 100644 index 000..e6a051d --- /dev/null +++ b/content/js/

[3/5] flink-web git commit: Rebuild website

2018-03-27 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink-web/blob/d37cedd8/content/material.html -- diff --git a/content/material.html b/content/material.html index b6937c1..ed1ec6c 100644 --- a/content/material.html +++ b/content/material.htm

[1/5] flink-web git commit: [FLINK-9062] Ship jQuery without external provider

2018-03-27 Thread twalthr
Repository: flink-web Updated Branches: refs/heads/asf-site ae3a7e4c2 -> d37cedd8a http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0107ae8/js/jquery.min.js -- diff --git a/js/jquery.min.js b/js/jquery.min.js new file mod

[2/5] flink-web git commit: [FLINK-9062] Ship jQuery without external provider

2018-03-27 Thread twalthr
[FLINK-9062] Ship jQuery without external provider Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f0107ae8 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/f0107ae8 Diff: http://git-wip-us.apache.org/repos/

flink git commit: [hotfix] [docs] Fix missing license header

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 3a61ea479 -> d6d0cb97c [hotfix] [docs] Fix missing license header Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d6d0cb97 Tree: http://git-wip-us.apache.org/repos/asf/

flink git commit: [hotfix] [docs] Fix missing license header

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 fb98e2a3b -> 9b12dcdc3 [hotfix] [docs] Fix missing license header Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9b12dcdc Tree: http://git-wip-us.apache.org/repos

flink git commit: [hotfix] [docs] Fix missing license header

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 e3b95a70a -> 0a9e10f53 [hotfix] [docs] Fix missing license header Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a9e10f5 Tree: http://git-wip-us.apache.org/repos

flink git commit: [hotfix] [docs] Fix missing license header

2018-03-27 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.3 cb50c20c2 -> b04f6d751 [hotfix] [docs] Fix missing license header Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b04f6d75 Tree: http://git-wip-us.apache.org/repos

flink git commit: [FLINK-8973] [E2E] HA end-to-end test with StateMachineExample.

2018-04-03 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 6d0d366eb -> a666455c9 [FLINK-8973] [E2E] HA end-to-end test with StateMachineExample. Adds an end-to-end test that runs the StateMachineExample on a local cluster with HA enabled. There is a single JM which gets killed and re-created and w

flink git commit: [FLINK-8973] [E2E] HA end-to-end test with StateMachineExample.

2018-04-03 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 6ec1aab0a -> dffbf4181 [FLINK-8973] [E2E] HA end-to-end test with StateMachineExample. Adds an end-to-end test that runs the StateMachineExample on a local cluster with HA enabled. There is a single JM which gets killed and re-created

flink git commit: [FLINK-8507] [table] Upgrade Calcite dependency to 1.16

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 37fe082bd -> 3e21f0f8e [FLINK-8507] [table] Upgrade Calcite dependency to 1.16 This closes #5791. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e21f0f8 Tree: http:/

flink git commit: [FLINK-8507] [table] Upgrade Calcite dependency to 1.16

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 69b9515b4 -> 7e240edca [FLINK-8507] [table] Upgrade Calcite dependency to 1.16 This closes #5791. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e240edc Tree: h

flink git commit: [FLINK-8563] [table] Add test for consecutive DOT access of composite array element in SQL

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 3e21f0f8e -> 284995172 [FLINK-8563] [table] Add test for consecutive DOT access of composite array element in SQL This closes #5792. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/as

flink git commit: [FLINK-8563] [table] Add test for consecutive DOT access of composite array element in SQL

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 198446962 -> 4b10dd684 [FLINK-8563] [table] Add test for consecutive DOT access of composite array element in SQL This closes #5792. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/rep

flink git commit: [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master a71b90318 -> 98a8b642f [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo This closes #5794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98

flink git commit: [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 4b10dd684 -> a298e6e4f [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo This closes #5794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

flink git commit: [FLINK-8508] [table] Remove RexSimplify class from Flink

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 98a8b642f -> 176a893d2 [FLINK-8508] [table] Remove RexSimplify class from Flink This closes #5793. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/176a893d Tree: http:

flink git commit: [FLINK-8508] [table] Remove RexSimplify class from Flink

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 a298e6e4f -> 2c626d140 [FLINK-8508] [table] Remove RexSimplify class from Flink This closes #5793. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c626d14 Tree:

flink git commit: [FLINK-9110] [docs] Fix local bundler installation

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 176a893d2 -> 29fbc95ca [FLINK-9110] [docs] Fix local bundler installation This closes #5788. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29fbc95c Tree: http://git-

flink git commit: [FLINK-9110] [docs] Fix local bundler installation

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 2c626d140 -> 4e7b15dad [FLINK-9110] [docs] Fix local bundler installation This closes #5788. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e7b15da Tree: http:/

flink git commit: [FLINK-9110] [docs] Fix local bundler installation

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 492dcb176 -> 7610b597b [FLINK-9110] [docs] Fix local bundler installation This closes #5788. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7610b597 Tree: http:/

flink-web git commit: [hotfix] Sync build script with FLINK-9110

2018-04-04 Thread twalthr
Repository: flink-web Updated Branches: refs/heads/asf-site d37cedd8a -> 8b7c2dcb2 [hotfix] Sync build script with FLINK-9110 Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/8b7c2dcb Tree: http://git-wip-us.apache.

flink git commit: [FLINK-9107] [docs] Document timer coalescing for ProcessFunction

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/master bd8b47956 -> 7b0fc58f7 [FLINK-9107] [docs] Document timer coalescing for ProcessFunction This closes #5790. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b0fc58f Tr

flink git commit: [FLINK-9107] [docs] Document timer coalescing for ProcessFunction

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 2ae48534e -> f083622a2 [FLINK-9107] [docs] Document timer coalescing for ProcessFunction This closes #5790. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f08362

flink git commit: [FLINK-9107] [docs] Document timer coalescing for ProcessFunction

2018-04-04 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 7610b597b -> ca8f4ca4f [FLINK-9107] [docs] Document timer coalescing for ProcessFunction This closes #5790. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca8f4c

flink git commit: [FLINK-9059] [table] Replace "sources" with "tables" in environment file

2018-04-06 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 7baf7649e -> bc9982c36 [FLINK-9059] [table] Replace "sources" with "tables" in environment file This closes #5758. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc99

flink git commit: [FLINK-9059] [table] Replace "sources" with "tables" in environment file

2018-04-06 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 764bafdd4 -> ff3a0ec69 [FLINK-9059] [table] Replace "sources" with "tables" in environment file This closes #5758. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit

flink git commit: [FLINK-9145] [table] Clean up flink-table dependencies

2018-04-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 71c3cd278 -> 185b904aa [FLINK-9145] [table] Clean up flink-table dependencies This closes #5853. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/185b904a Tree: http://

flink git commit: [FLINK-9145] [table] Clean up flink-table dependencies

2018-04-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 f97c0c15e -> c6d45b922 [FLINK-9145] [table] Clean up flink-table dependencies This closes #5853. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c6d45b92 Tree: ht

flink git commit: [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss

2018-04-19 Thread twalthr
Repository: flink Updated Branches: refs/heads/master d1725a9a2 -> 96f675ca0 [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss This change replaces Hadoop's LocalFileSystem (which is a checksumming filesystem) with the RawFileSystem implementation. F

flink git commit: [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss

2018-04-19 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 2ccdf07da -> 5621a1e9f [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss This change replaces Hadoop's LocalFileSystem (which is a checksumming filesystem) with the RawFileSystem implementati

flink git commit: [FLINK-8980] [e2e] Add a BucketingSink end-to-end test

2018-04-19 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 96f675ca0 -> 42828e021 [FLINK-8980] [e2e] Add a BucketingSink end-to-end test This closes #5813. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42828e02 Tree: http://

flink git commit: [FLINK-8980] [e2e] Add a BucketingSink end-to-end test

2018-04-19 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 5621a1e9f -> 3df5c6685 [FLINK-8980] [e2e] Add a BucketingSink end-to-end test This closes #5813. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3df5c668 Tree: ht

flink git commit: [FLINK-9227] [test] Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 42828e021 -> 321039f78 [FLINK-9227] [test] Add Bucketing e2e test script to run-nightly-tests.sh This closes #5884. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/321

flink git commit: [FLINK-9227] [test] Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 3df5c6685 -> f47c201f8 [FLINK-9227] [test] Add Bucketing e2e test script to run-nightly-tests.sh This closes #5884. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commi

flink git commit: [hotfix] [e2e] Update flink-bucketing-sink-test version to 1.5-SNAPSHOT

2018-04-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 f47c201f8 -> 537f452d9 [hotfix] [e2e] Update flink-bucketing-sink-test version to 1.5-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/537f452d Tree: http:

[1/2] flink git commit: [FLINK-8600] Allow disabling truncate() check in BucketingSink

2018-04-23 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 ba8d72ab5 -> 896797be7 [FLINK-8600] Allow disabling truncate() check in BucketingSink The test was failing when using PrestoS3FileSystem because it doesn't use an absolute/qualified path. Project: http://git-wip-us.apache.org/repos/a

[2/2] flink git commit: [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss

2018-04-23 Thread twalthr
[FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss This change replaces Hadoop's LocalFileSystem (which is a checksumming filesystem) with the RawFileSystem implementation. For performing checksums the default filesystem only flushes in 512 byte interval

[2/2] flink git commit: [FLINK-8537] [table] Add a Kafka table source factory with Avro format support

2018-04-24 Thread twalthr
[FLINK-8537] [table] Add a Kafka table source factory with Avro format support This closes #5610. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/614b1e29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/614b1e29 Diff:

[1/2] flink git commit: [FLINK-8537] [table] Add a Kafka table source factory with Avro format support

2018-04-24 Thread twalthr
Repository: flink Updated Branches: refs/heads/master cdf4744ba -> 614b1e29e http://git-wip-us.apache.org/repos/asf/flink/blob/614b1e29/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/wmstrategies/AscendingTimestamps.scala --

flink git commit: [FLINK-9229] [table] Fix literal handling in code generation

2018-04-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/master c50b573e9 -> 063aeb17d [FLINK-9229] [table] Fix literal handling in code generation This closes #5898. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/063aeb17 Tree: h

flink git commit: [FLINK-9229] [table] Fix literal handling in code generation

2018-04-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 2429a7b1a -> dfa675072 [FLINK-9229] [table] Fix literal handling in code generation This closes #5898. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dfa67507 Tr

flink git commit: [FLINK-9229] [table] Fix literal handling in code generation

2018-04-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 471e067dc -> 963f14e26 [FLINK-9229] [table] Fix literal handling in code generation This closes #5898. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/963f14e2 Tr

flink git commit: [FLINK-8686] [sql-client] Improve basic embedded SQL client

2018-04-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 063aeb17d -> fdfce98ab [FLINK-8686] [sql-client] Improve basic embedded SQL client - Fix invalid cached session properties - Sort given table source properties - Add logging for exceptions and cluster communication - Add valid page range -

flink git commit: [FLINK-8686] [sql-client] Improve basic embedded SQL client

2018-04-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 dfa675072 -> 3ca925a06 [FLINK-8686] [sql-client] Improve basic embedded SQL client - Fix invalid cached session properties - Sort given table source properties - Add logging for exceptions and cluster communication - Add valid page ran

[flink] branch master updated: [FLINK-12968][table-common] Add an utility for finding a common type from a set of types

2019-07-08 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr 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 3bcd47f [FLINK-12968][table-common] Add an

[flink] branch master updated: [FLINK-11727][formats] Fixed JSON format issues after serialization

2019-07-15 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr 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 38e4e2b [FLINK-11727][formats] Fixed JSON

[flink] branch release-1.9 updated: [FLINK-11727][formats] Fixed JSON format issues after serialization

2019-07-15 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new 8883534 [FLINK-11727][formats] Fixed

[flink] branch master updated: [FLINK-13264][table] Let the planner supply its type inference util

2019-07-15 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr 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 0fe634c [FLINK-13264][table] Let the planner

[flink] branch release-1.9 updated: [FLINK-13264][table] Let the planner supply its type inference util

2019-07-15 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new 4184049 [FLINK-13264][table] Let the

[flink] 02/04: [FLINK-13287][table-planner] Support Reinterpret cast call in blink planner

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2893f3f597ea3574636d0376bd7823b547fd2217 Author: JingsongLi AuthorDate: Wed Jul 17 20:20:22 2019 +0800 [FLINK

[flink] 03/04: [FLINK-13287][table-api] Port ExistingField to api-java and use new Expression in FieldComputer

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 514b51de832fec320caf9cc73eb39d35910a1c79 Author: JingsongLi AuthorDate: Wed Jul 17 20:23:37 2019 +0800 [FLINK

[flink] branch master updated (07ce142 -> 2e3aab3)

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 07ce142 [FLINK-12578][build] Add fallback unsafe MapR repository new 678fce0 [FLINK-13287][table-planner

[flink] 04/04: [FLINK-13287][table-api] Port StreamRecordTimestamp to api-java

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2e3aab3f6464ecae7f60a561ae7541296ce5681c Author: JingsongLi AuthorDate: Wed Jul 17 20:25:04 2019 +0800 [FLINK

[flink] 01/04: [FLINK-13287][table-planner] Support STREAM_RECORD_TIMESTAMP call in table planner

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 678fce06587a3df4693acbcc5f3a9fb32396aabe Author: JingsongLi AuthorDate: Wed Jul 17 20:18:56 2019 +0800 [FLINK

[flink] branch release-1.9 updated (41e56d9 -> c43dc95)

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git. from 41e56d9 [FLINK-12578][build] Add fallback unsafe MapR repository new 07e70a9 [FLINK-13287][table-planner

[flink] 01/04: [FLINK-13287][table-planner] Support STREAM_RECORD_TIMESTAMP call in table planner

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 07e70a927ee36cd5eda85eece6b221086fe335ff Author: JingsongLi AuthorDate: Wed Jul 17 20:18:56 2019 +0800 [FLINK

[flink] 02/04: [FLINK-13287][table-planner] Support Reinterpret cast call in blink planner

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit fa5c8674a6a2bcdbcc7ed898e98a89e3b2f92c50 Author: JingsongLi AuthorDate: Wed Jul 17 20:20:22 2019 +0800 [FLINK

[flink] 04/04: [FLINK-13287][table-api] Port StreamRecordTimestamp to api-java

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit c43dc951bf52e2f76a9c17021cfdf1ca8bc54781 Author: JingsongLi AuthorDate: Wed Jul 17 20:25:04 2019 +0800 [FLINK

[flink] 03/04: [FLINK-13287][table-api] Port ExistingField to api-java and use new Expression in FieldComputer

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 121e35ec66dbaf40ca763e1a8551c480cea03215 Author: JingsongLi AuthorDate: Wed Jul 17 20:23:37 2019 +0800 [FLINK

[flink] branch master updated: [FLINK-13315][api-java] Port wmstrategies to api-java-bridge

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr 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 de1a8a0 [FLINK-13315][api-java] Port

[flink] branch release-1.9 updated: [FLINK-13315][api-java] Port wmstrategies to api-java-bridge

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new 66edf7d [FLINK-13315][api-java] Port

[flink] 04/06: [FLINK-13078][table-common] Simplify serializable string representation for parsers

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f6c65fc2d8e2817b823172a65a54df9a0361371a Author: Timo Walther AuthorDate: Wed Jul 10 08:46:29 2019 +0200 [FLINK

[flink] 06/06: [FLINK-13078][table-common] Add a logical type parser

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 479fb070edc4a681d85e4c20a964083751aa3720 Author: Timo Walther AuthorDate: Wed Jul 10 08:52:30 2019 +0200 [FLINK

[flink] 01/06: [hotfix][table-common] Fix minor typos in ObjectIdentifier

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 3f62d5d78a3f792e3fb984ff88d38190dabad586 Author: Timo Walther AuthorDate: Wed Jul 10 08:40:47 2019 +0200 [hotfix

[flink] 03/06: [hotfix][table-common] Link timestamp precisions

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8f3e7b91e0d2d1991bbc77d227a71fff751cac0d Author: Timo Walther AuthorDate: Wed Jul 10 08:44:08 2019 +0200 [hotfix

[flink] 02/06: [hotfix][table-common] Update list of synonyms for logical types

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 178a7ea08cbff001375734a24e9e20fd94006fac Author: Timo Walther AuthorDate: Wed Jul 10 08:43:18 2019 +0200 [hotfix

[flink] branch master updated (de1a8a0 -> 479fb07)

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from de1a8a0 [FLINK-13315][api-java] Port wmstrategies to api-java-bridge new 3f62d5d [hotfix][table-common] Fix

[flink] 05/06: [FLINK-13078][table-common] Add an unresolved user-defined logical type

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 29fcd0c65900256222e954b7d91743053c379694 Author: Timo Walther AuthorDate: Wed Jul 10 08:51:22 2019 +0200 [FLINK

[flink] 04/06: [FLINK-13078][table-common] Simplify serializable string representation for parsers

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit e750efc0a84c039f42f1edc81257f9fab0de03d9 Author: Timo Walther AuthorDate: Wed Jul 10 08:46:29 2019 +0200

[flink] 01/06: [hotfix][table-common] Fix minor typos in ObjectIdentifier

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 3c443a0ea4da5103ebe4abe26f1da2b639a8206b Author: Timo Walther AuthorDate: Wed Jul 10 08:40:47 2019 +0200

[flink] 02/06: [hotfix][table-common] Update list of synonyms for logical types

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 15ef025bd387716b1a2259ea238bd1222623af76 Author: Timo Walther AuthorDate: Wed Jul 10 08:43:18 2019 +0200

[flink] 05/06: [FLINK-13078][table-common] Add an unresolved user-defined logical type

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit e5d4ec09bfa635590b1a5d506a3b6dee714cbc62 Author: Timo Walther AuthorDate: Wed Jul 10 08:51:22 2019 +0200

[flink] 03/06: [hotfix][table-common] Link timestamp precisions

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit d05b436024888e554033a64839056f1b4dfbfcb6 Author: Timo Walther AuthorDate: Wed Jul 10 08:44:08 2019 +0200

[flink] 06/06: [FLINK-13078][table-common] Add a logical type parser

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit b2922105e08ac307835022acbf0bab4ed819d862 Author: Timo Walther AuthorDate: Wed Jul 10 08:52:30 2019 +0200

[flink] branch release-1.9 updated (66edf7d -> b292210)

2019-07-18 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git. from 66edf7d [FLINK-13315][api-java] Port wmstrategies to api-java-bridge new 3c443a0 [hotfix][table-common

[flink] 01/02: [FLINK-13266] [table] move ExpressionParserException & UnresolvedException to table-common module

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e504957ca359fbc62004b4bd1386640254780a36 Author: godfreyhe AuthorDate: Wed Jul 17 20:08:01 2019 +0800 [FLINK-13266

[flink] branch master updated (c75af84 -> 7ba2298)

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c75af84 [FLINK-13326] Support async rawState checkpointing new e504957 [FLINK-13266] [table] move

[flink] 02/02: [FLINK-13266] [table] remove definedTimeAttributes file in blink planner

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7ba22989f46444754f736ad3ef337736d5b2a9c4 Author: godfreyhe AuthorDate: Wed Jul 17 20:13:56 2019 +0800 [FLINK-13266

[flink] 02/02: [FLINK-13266] [table] remove definedTimeAttributes file in blink planner

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 85636497642ccd054f4a09eb2aa1b2eed6b3ed88 Author: godfreyhe AuthorDate: Wed Jul 17 20:13:56 2019 +0800 [FLINK

[flink] 01/02: [FLINK-13266] [table] move ExpressionParserException & UnresolvedException to table-common module

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit f2db40bfb5db641e554e4f09b5f9d58969dac551 Author: godfreyhe AuthorDate: Wed Jul 17 20:08:01 2019 +0800 [FLINK

[flink] branch release-1.9 updated (aceaca6 -> 8563649)

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git. from aceaca6 [FLINK-13221][table-planner-blink] Blink planner should set ScheduleMode to

[flink] 02/02: [FLINK-13266][table-common] Improve comment for FilterableTableTableSource

2019-07-22 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 71283e27e2b4ca5274f791d46e085b940b8cf215 Author: godfreyhe AuthorDate: Fri Jul 19 16:01:57 2019 +0800 [FLINK-13266

<    8   9   10   11   12   13   14   15   16   17   >