flink git commit: Commit for release 0.10.2

Repository: flink Updated Branches: refs/heads/release-0.10.2-rc2 [created] e525eb2f1 Commit for release 0.10.2 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e525eb2f Tree:

[2/2] flink git commit: [FLINK-3336] Add Rescale Data Shipping for DataStream

[FLINK-3336] Add Rescale Data Shipping for DataStream This is the Javadoc of DataStream.rescale() that describes the behaviour: Sets the partitioning of the {@link DataStream} so that the output elements are distributed evenly to a subset of instances of the next operation in a round-robin

[1/2] flink git commit: [hotfix] Remove @Experimental from DataStream.forward()

Repository: flink Updated Branches: refs/heads/master 7469c17cb -> 412dcbdf5 [hotfix] Remove @Experimental from DataStream.forward() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/412dcbdf Tree:

flink git commit: [FLINK-3362] [runtime] Fix possible overflow in multiplication

Repository: flink Updated Branches: refs/heads/master e0fd489bb -> 6d83c9d95 [FLINK-3362] [runtime] Fix possible overflow in multiplication Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d83c9d9 Tree:

flink git commit: [FLINK-3339] Make ValueState.update(null) act as ValueState.clear()

Repository: flink Updated Branches: refs/heads/master 6d83c9d95 -> 7469c17cb [FLINK-3339] Make ValueState.update(null) act as ValueState.clear() This was causing problems with TypeSerializers that choke on null values, especially in the Scala KeyedStream.*WithState() family of functions.

[06/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/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

[01/12] flink git commit: [hotfix] [docs] Add config docs about checkpoint stats

Repository: flink Updated Branches: refs/heads/master 20f8911b4 -> ba13caa1b [hotfix] [docs] Add config docs about checkpoint stats Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d69fe309 Tree:

[12/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

[FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend) This closes #1578. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba13caa1 Tree:

[11/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/flink-runtime-web/web-dashboard/web/css/vendor.css -- diff --git a/flink-runtime-web/web-dashboard/web/css/vendor.css b/flink-runtime-web/web-dashboard/web/css/vendor.css

[10/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot

[03/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web monitor (backend)

http://git-wip-us.apache.org/repos/asf/flink/blob/b7e70da3/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JobVertexBackPressureHandlerTest.java -- diff --git

[04/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web monitor (backend)

[FLINK-3310] [runtime-web] Add back pressure statistics to web monitor (backend) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b7e70da3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b7e70da3 Diff:

[02/12] flink git commit: [hotfix] [runtime] Create TestingJobManager in TestingUtils

[hotfix] [runtime] Create TestingJobManager in TestingUtils Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/41470408 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/41470408 Diff:

[05/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.html

[07/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

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

[08/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf

[09/12] flink git commit: [FLINK-3310] [runtime-web] Add back pressure statistics to web dashboard (frontend)

http://git-wip-us.apache.org/repos/asf/flink/blob/ba13caa1/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.svg -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.svg

flink git commit: [tools] Properly update all POM versions in release script

Repository: flink Updated Branches: refs/heads/release-0.10 0c8a9ce2b -> 2cd06181f [tools] Properly update all POM versions in release script - Missing backport from master branch - Previous version missed quickstart archetype poms Project: http://git-wip-us.apache.org/repos/asf/flink/repo

flink git commit: [hotfix][doc] Add note on how to use custom loggers with a per-job-yarn cluster

Repository: flink Updated Branches: refs/heads/master ba13caa1b -> 22423e23f [hotfix][doc] Add note on how to use custom loggers with a per-job-yarn cluster Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22423e23 Tree:

[2/2] flink git commit: [FLINK-3348][scripts] remove bc dependency in startup script

[FLINK-3348][scripts] remove bc dependency in startup script Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af425b29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/af425b29 Diff:

[1/2] flink git commit: [FLINK-3353] CSV-related tests may fail depending on locale

Repository: flink Updated Branches: refs/heads/master 412dcbdf5 -> 20f8911b4 [FLINK-3353] CSV-related tests may fail depending on locale This closes #1598. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20f8911b Tree:

[6/9] flink git commit: [hotfix] typo IllegalArgumentException

[hotfix] typo IllegalArgumentException This closes #1602 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c47f385 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c47f385 Diff:

[5/9] flink git commit: [FLINK-3334] [conf] Include year-month-day in the log output

[FLINK-3334] [conf] Include year-month-day in the log output Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d51bec15 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d51bec15 Diff:

[2/9] flink git commit: [FLINK-3363] [jobmanager] Properly shut down executor thread pool when JobManager shuts down

[FLINK-3363] [jobmanager] Properly shut down executor thread pool when JobManager shuts down Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a277543c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a277543c Diff:

[7/9] flink git commit: [FLINK-3357] [core] Drop AbstractID#toShortString()

[FLINK-3357] [core] Drop AbstractID#toShortString() This closes #1601 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28feede7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28feede7 Diff:

[4/9] flink git commit: [FLINK-3337] [runtime] mvn test fails on flink-runtime because curator classes not found

[FLINK-3337] [runtime] mvn test fails on flink-runtime because curator classes not found Removes curator dependency exclusions from flink-runtime. This resolves NoClassDefFoundError exceptions when running `mvn test`. This partialy reverts e31a4d8. This closes #1596 Project:

[8/9] flink git commit: [hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant

[hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9c83ea2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9c83ea2 Diff:

[1/9] flink git commit: [FLINK-3365] [taskmanager] Properly shut down cleanup timer thread

Repository: flink Updated Branches: refs/heads/master 22423e23f -> 28c6254ee [FLINK-3365] [taskmanager] Properly shut down cleanup timer thread Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/457cb145 Tree: