flink git commit: [hotfix] [FLINK-3679] Improve Javadocs of DeserializationSchemas

Repository: flink Updated Branches: refs/heads/master c39ad31f3 -> 96d24445e [hotfix] [FLINK-3679] Improve Javadocs of DeserializationSchemas Javadocs of the `deserialize(...)` method should inform that returning null from the method is allowed, if the message cannot be deserialized.

[2/2] flink git commit: [FLINK-3679] [kafka] Improve null record handling for FlinkKafkaConsumer

[FLINK-3679] [kafka] Improve null record handling for FlinkKafkaConsumer This commit generally improves null record handling by: - also update the offset in state holders if record is null - move null record related tests to AbstractFetcherTest, so that behaviour is tested for all fetcher

[1/2] flink git commit: [FLINK-3679] [kafka] Allow Kafka consumer to skip corrupted messages

Repository: flink Updated Branches: refs/heads/master adbf846f2 -> c39ad31f3 [FLINK-3679] [kafka] Allow Kafka consumer to skip corrupted messages Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/afb4c5e0 Tree:

Build failed in Jenkins: flink-snapshot-deployment #398

See -- [...truncated 170.16 KB...] [ERROR] public FSDataOutputStream create(Path f, boolean overwrite) throws IOException { [ERROR] ^ [ERROR]

buildbot failure in on flink-docs-release-1.2

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

flink git commit: [FLINK-5983] [table] Convert FOR into WHILE loops for aggregation functions.

Repository: flink Updated Branches: refs/heads/master 31a57c5a8 -> adbf846f2 [FLINK-5983] [table] Convert FOR into WHILE loops for aggregation functions. This closes #3489. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-5047] [table] Add sliding group-windows for batch tables

[FLINK-5047] [table] Add sliding group-windows for batch tables This closes #3364. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31a57c5a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31a57c5a Diff:

[1/2] flink git commit: [FLINK-5047] [table] Add sliding group-windows for batch tables

Repository: flink Updated Branches: refs/heads/master bec818d84 -> 31a57c5a8 http://git-wip-us.apache.org/repos/asf/flink/blob/31a57c5a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala

flink git commit: [FLINK-5414] [table] Bump up Calcite version to 1.11. (Jark Wu and Haohui Mai)

Repository: flink Updated Branches: refs/heads/master 121b12b7c -> bec818d84 [FLINK-5414] [table] Bump up Calcite version to 1.11. (Jark Wu and Haohui Mai) This closes #3338. This closes #3426. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI

[FLINK-3427] [webui] Rebuild web UI This closes #3366. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/121b12b7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/121b12b7 Diff:

[1/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI

Repository: flink Updated Branches: refs/heads/master 7a629fc59 -> 121b12b7c http://git-wip-us.apache.org/repos/asf/flink/blob/121b12b7/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.html -- diff --git

[5/5] flink git commit: [FLINK-3427] [webui] Add watermark tracking

[FLINK-3427] [webui] Add watermark tracking Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d84b65ff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d84b65ff Diff:

[4/5] flink git commit: [FLINK-3427] [webui] Refactorings to watermark tracking

[FLINK-3427] [webui] Refactorings to watermark tracking Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ef18f65 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4ef18f65 Diff:

[2/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI

http://git-wip-us.apache.org/repos/asf/flink/blob/121b12b7/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js b/flink-runtime-web/web-dashboard/web/js/vendor.js index

flink git commit: [FLINK-5722] [table] Add dedicated DataSetDistinct operator.

Repository: flink Updated Branches: refs/heads/master 338c30a41 -> 7a629fc59 [FLINK-5722] [table] Add dedicated DataSetDistinct operator. - Uses hash-combiner for more better combine rate. This closes #3471. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-4326] [scripts] Flink foreground services

Repository: flink Updated Branches: refs/heads/master e9a5c8629 -> 338c30a41 [FLINK-4326] [scripts] Flink foreground services Add a "start-foreground" option to the Flink service scripts which does not daemonize the service nor redirect output. This closes #3492. This closes #3351.