flink git commit: FLINK-7366 Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5

2017-08-30 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master df7452d98 -> b915757f5 FLINK-7366 Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5 This closes #4522 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-7559] [quickstart] fix Typo in flink-quickstart pom

2017-08-30 Thread chesnay
Repository: flink Updated Branches: refs/heads/master b915757f5 -> e753db841 [FLINK-7559] [quickstart] fix Typo in flink-quickstart pom This closes #4619. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1b7f8bd8 Tree:

[2/2] flink git commit: [FLINK-7556] Allow Integer.MIN_VALUE for fetch size in JDBCInputFormat

2017-08-30 Thread chesnay
[FLINK-7556] Allow Integer.MIN_VALUE for fetch size in JDBCInputFormat Allow Integer.MIN_VALUE to be accepted as a parameter for setFetchSize for MySQL Driver. The combination of a forward-only, read-only result set, with a fetch size of Integer.MIN_VALUE serves as a signal to the driver to

flink git commit: [FLINK-7558][table]Improve SQL ValidationException message.

2017-08-30 Thread jincheng
Repository: flink Updated Branches: refs/heads/master e753db841 -> e6fddbc3e [FLINK-7558][table]Improve SQL ValidationException message. This closes #4620 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e6fddbc3 Tree: