[5/5] flink git commit: [FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ

2016-01-28 Thread sewen
[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ This closes #1534 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b01a890 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b01a890 Diff:

[3/5] flink git commit: [FLINK-3242] Also Set User-specified StateBackend without Checkpointing

2016-01-28 Thread sewen
[FLINK-3242] Also Set User-specified StateBackend without Checkpointing Before, the user-specified StateBackedn would not be set when generating the JobGraph if checkpointing was disabled. This closes #1516 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/5] flink git commit: [FLINK-3292]Fix for Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread sewen
[FLINK-3292]Fix for Bug in flink-jdbc. Not all JDBC drivers supported This closes #1551 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d97fcda6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d97fcda6 Diff:

[1/5] flink git commit: [FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/master 2e2330737 -> 6b01a8902 [FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator This closes #1542 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3242] Adjust StateBackendITCase for 0.10 signatures of state backends

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 2aeb6fac3 -> bef39f881 [FLINK-3242] Adjust StateBackendITCase for 0.10 signatures of state backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bef39f88

flink git commit: [FLINK-3275] [py] Support for DataSet.setParallelism()

2016-01-28 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 440137cc3 -> 40422d505 [FLINK-3275] [py] Support for DataSet.setParallelism() -parallelism is stored Value object within the OperationInfo, so it can be passed as a reference to multiple operations (in cases where a set is internally

flink git commit: [FLINK-3140] [table] NULL value data layout in Row Serializer/Comparator

2016-01-28 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 499b60fed -> 440137cc3 [FLINK-3140] [table] NULL value data layout in Row Serializer/Comparator This closes #1465. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[09/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
[FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies Several packages had been updated locally by users when compiling the templates without changing the version in bower.json. The following packages have been explicitly updated. jquery 2.1.4 → 2.2.0

[08/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.svg -- diff --git a/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.svg

[03/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf

[05/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot

[11/11] flink git commit: [hotfix] [streaming] Processing timer errors are not logged unless the task is actually running.

2016-01-28 Thread sewen
[hotfix] [streaming] Processing timer errors are not logged unless the task is actually running. This keeps the log cleaner in case of failed timers while canceling tasks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[04/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.svg -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.svg

[06/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/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

[01/11] flink git commit: [FLINK-3262] [web-dashboard] Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/master 40422d505 -> 2e2330737 http://git-wip-us.apache.org/repos/asf/flink/blob/1ea5e138/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git

[10/11] flink git commit: [hotfix] [kafka connector] Replace funky loop with simple division in FixedPartitioner

2016-01-28 Thread sewen
[hotfix] [kafka connector] Replace funky loop with simple division in FixedPartitioner Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9637ee78 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9637ee78 Diff:

flink git commit: [FLINK-3242] Also Set User-specified StateBackend without Checkpointing

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 dfeee2372 -> 2aeb6fac3 [FLINK-3242] Also Set User-specified StateBackend without Checkpointing Before, the user-specified StateBackedn would not be set when generating the JobGraph if checkpointing was disabled. This closes #1516