[hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide".
This closes #3153.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db230a97
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db230a97
[FLINK-5452] [table] Fix SortITCase which fails under cluster mode.
This closes #3095.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f769261
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f769261
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 080617d28 -> 9073c53f9
[FLINK-5520] [table] Disable outer joins with non-equality predicates.
This closes #3141.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5417] [docs] Fix config file name in slots_parallelism.svg
This closes #3071.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c03491c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c03491c
Diff:
[FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS
This closes #2991.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b36b43b9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b36b43b9
Diff:
[FLINK-5329] Fix metric list being cut off
This closes #3109.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8c34d45
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8c34d45
Diff:
[hotfix] [doc] Fix several broken "Linking with Flink" links
This closes #3137.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a2970a3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6a2970a3
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/883fc5a7/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
[FLINK-5150] [webui] Store metrics in sessionStorage
This closes #3104.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cbd933bd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cbd933bd
Diff:
[FLINK-5434] Remove unsupported project() transformation from Scala DataStream
docs.
This closes #3121.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a7437cca
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/525edf1e/flink-tests/src/test/java/org/apache/flink/test/classloading/jar/LegacyCheckpointedStreamingProgram.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/6c03491c/docs/fig/slots_parallelism.svg
--
diff --git a/docs/fig/slots_parallelism.svg b/docs/fig/slots_parallelism.svg
index 14e0960..11c2ec9 100644
---
[FLINK-5113] Port functions in tests to new CheckpointedFunction IF.
This closes #2939.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/525edf1e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/525edf1e
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/7f20bd0d/docs/setup/yarn_setup.md
--
diff --git a/docs/setup/yarn_setup.md b/docs/setup/yarn_setup.md
index 5f6855f..53423b8 100644
--- a/docs/setup/yarn_setup.md
+++
Repository: flink
Updated Branches:
refs/heads/release-1.2 92e393500 -> 080617d28
[FLINK-5380] Fix task metrics reuse for single-operator chains
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/792f7e45
Tree:
Rebuild web-dashboard
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/883fc5a7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/883fc5a7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/883fc5a7
Branch:
[hotfix] [doc] Fix several broken "Linking with Flink" links
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64c4c9dd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/64c4c9dd
Diff:
[FLINK-5434] Remove unsupported project() transformation from Scala DataStream
docs.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebf4443a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebf4443a
Diff:
[FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2bbc92cf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2bbc92cf
Diff:
[FLINK-5432] recursively scan nested files in ContinuousFileMonitoringFunction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28c18e22
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28c18e22
Diff:
[FLINK-5113] Port functions in tests to new CheckpointedFunction IF.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b069fde
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b069fde
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/6c03491c/docs/setup/yarn_setup.md
--
diff --git a/docs/setup/yarn_setup.md b/docs/setup/yarn_setup.md
index 5f6855f..53423b8 100644
--- a/docs/setup/yarn_setup.md
+++
Repository: flink
Updated Branches:
refs/heads/master d1301c82b -> 883fc5a77
[FLINK-5432] recursively scan nested files in ContinuousFileMonitoringFunction
This closes #3090.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Rebuild web-dashboard
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/080617d2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/080617d2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/080617d2
Branch:
[FLINK-5424] Improve Restart Strategy Logging
- Added toString for FailureRateRestartStrategy (important for
JobManager's "Using restart strategy $restartStrategy" log message)
- Added explanation in log when the restart strategy is responsible
for preventing job restart
This closes #3079.
[FLINK-5424] Improve Restart Strategy Logging
- Added toString for FailureRateRestartStrategy (important for
JobManager's "Using restart strategy $restartStrategy" log message)
- Added explanation in log when the restart strategy is responsible
for preventing job restart
Project:
[FLINK-5380] Fix task metrics reuse for single-operator chains
This closes #3068.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb059157
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb059157
Diff:
[FLINK-5493] Fix String formats in FlinkDistributionOverlay and Task
This closes #3010.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d830cac8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d830cac8
Diff:
[FLINK-5419] Make full TM metrics available through REST API
This closes #3092.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c93e04c1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c93e04c1
Diff:
[FLINK-4920] Introduce Scala Function Gauge
This closes #3080.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/570dbc8d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/570dbc8d
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/080617d2/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
[FLINK-5150] [webui] Store metrics in sessionStorage
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/79b68263
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/79b68263
Diff:
[FLINK-5329] Fix metric list being cut off
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8cdbe44a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8cdbe44a
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/8b069fde/flink-tests/src/test/java/org/apache/flink/test/classloading/jar/LegacyCheckpointedStreamingProgram.java
--
diff --git
[FLINK-5493] Fix String formats in FlinkDistributionOverlay and Task
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82a6b83e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/82a6b83e
Diff:
[FLINK-5419] Make full TM metrics available through REST API
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f90edc48
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f90edc48
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/7f20bd0d/docs/fig/slots_parallelism.svg
--
diff --git a/docs/fig/slots_parallelism.svg b/docs/fig/slots_parallelism.svg
index 14e0960..11c2ec9 100644
---
[FLINK-5417] [docs] Fix config file name in slots_parallelism.svg
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f20bd0d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f20bd0d
Diff:
[hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide".
This closes #3153.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c6e0ee9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0c6e0ee9
[FLINK-5452] [table] Fix SortITCase which fails under cluster mode.
This closes #3095.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ea996a6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0ea996a6
Diff:
Repository: flink
Updated Branches:
refs/heads/master 4833e74e7 -> d1301c82b
[FLINK-5520] [table] Disable outer joins with non-equality predicates.
This closes #3141.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/release-1.2 7f3c8ff81 -> 92e393500
[FLINK-5557] [docs] Fix link in library methods
This closes #3163
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/92e39350
Tree:
Repository: flink
Updated Branches:
refs/heads/master b86a3d761 -> 4833e74e7
[FLINK-5557] [docs] Fix link in library methods
This closes #3163
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4833e74e
Tree:
Repository: flink
Updated Branches:
refs/heads/release-1.2 a4853babe -> 7f3c8ff81
[FLINK-] Document how to debug event time using watermarks (+ kafka metrics)
This closes #3170
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master a18657dcc -> b86a3d761
[FLINK-] Document how to debug event time using watermarks (+ kafka metrics)
This closes #3170
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5519] [build] scala-maven-plugin version all change to 3.2.2
This closes #3132
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a18657dc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a18657dc
Diff:
[FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList
Also make sure that the serialization via the state backends' list states
matches the deserialization of the KvStateRequestSerializer#deserializeList
method.
So far, it was used this way but not made sure via tests.
This
[FLINK-5543] [client] Add a comment to the code about adding a
customCommandLine to the CLI
This closes #3144
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cda40a7f
Tree:
Repository: flink
Updated Branches:
refs/heads/master e1b2cd01c -> a18657dcc
[FLINK-5531] [docs] Fix SSL code-block/list formatting
This closes #3140
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac815d78
Tree:
Repository: flink
Updated Branches:
refs/heads/master 6fb9ebc4f -> e1b2cd01c
[FLINK-5556] [checkpointing] Report correct buffered bytes during alignment
This closes #3164.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/release-1.2 75f36811e -> a4853babe
[FLINK-5556] [checkpointing] Report correct buffered bytes during alignment
This closes #3164.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/release-1.2 d3a16d298 -> 75f36811e
[FLINK-5574] [docs] Add checkpoint monitoring docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75f36811
Tree:
Repository: flink
Updated Branches:
refs/heads/release-1.2 a988e6cc9 -> d3a16d298
[FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList
Also make sure that the serialization via the state backends' list states
matches the deserialization of the
[FLINK-5531] [docs] Fix SSL code-block/list formatting
This closes #3140
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0bcd9d6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0bcd9d6
Diff:
Repository: flink
Updated Branches:
refs/heads/master 2841401a7 -> 6fb9ebc4f
[FLINK-5574] [docs] Add checkpoint monitoring docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6fb9ebc4
Tree:
Repository: flink-web
Updated Branches:
refs/heads/asf-site 9ec0a879f -> ccdf85ae5
Added a page that redirects to the latest stable docs. We can link to this page
from older versions of the docs.
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit:
[hotfix] [webfrontend] Rename 'pending' subtask stat to 'pending_or_failed'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27a1e759
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27a1e759
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 57a395546 -> a988e6cc9
[FLINK-5560] [webfrontend] Align table header columns with body
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/772884ee
Tree:
[webfrontend] Rebuild web frontend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a988e6cc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a988e6cc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a988e6cc
Repository: flink
Updated Branches:
refs/heads/master c7415192e -> 2841401a7
[webfrontend] Rebuild web frontend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2841401a
Tree:
[FLINK-5560] [webfrontend] Align table header columns with body
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1be76f67
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1be76f67
Diff:
[hotfix] [webfrontend] Rename 'pending' subtask stat to 'pending_or_failed'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c151b2d5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c151b2d5
Diff:
Repository: flink
Updated Branches:
refs/heads/master 6d8b3f5a1 -> c7415192e
[FLINK-5423] [ml] Implement Stochastic Outlier Selection (SOS) algorithm
Implemented the Stochastic Outlier Selection algorithm in the Machine Learning
library, including the test code and scaladoc documentation.
Repository: flink
Updated Branches:
refs/heads/release-1.2 11ce80bc5 -> 57a395546
[FLINK-5377] [docs] Stress importance of UIDs for savepoints
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57a39554
Tree:
Repository: flink
Updated Branches:
refs/heads/master bf72a7c02 -> 6d8b3f5a1
[FLINK-5377] [docs] Stress importance of UIDs for savepoints
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d8b3f5a
Tree:
Repository: flink
Updated Branches:
refs/heads/release-1.2 a7644b171 -> 11ce80bc5
[FLINK-5512] [doc] Improve RabbitMQ documentation
This closes #3136.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11ce80bc
Tree:
Repository: flink
Updated Branches:
refs/heads/master 586f81813 -> bf72a7c02
[FLINK-5512] [doc] Improve RabbitMQ documentation
This closes #3136.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf72a7c0
Tree:
67 matches
Mail list logo