http://git-wip-us.apache.org/repos/asf/flink/blob/21e8e2dc/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionVertex.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/executi
[FLINK-4720] Implement archived ExecutionGraph
This closes #2577.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/21e8e2dc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/21e8e2dc
Diff: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master f6d866817 -> 21e8e2dcf
http://git-wip-us.apache.org/repos/asf/flink/blob/21e8e2dc/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java
---
Repository: flink
Updated Branches:
refs/heads/master 21e8e2dcf -> 9948d4844
[FLINK-4774] [metrics] Fix scope concatenation in QueryScopeInfo
This closes #2613.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9948d484
Tre
Repository: flink
Updated Branches:
refs/heads/master 9948d4844 -> a648f88fb
[FLINK-4827] [docs] Fix scala Streaming Table example
This closes #2632.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a648f88f
Tree: http://g
Repository: flink
Updated Branches:
refs/heads/master a612b9966 -> 436c3335b
[hotfix] Fix ArchivedExecutionGraphTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/436c3335
Tree: http://git-wip-us.apache.org/repos/asf/fli
Repository: flink
Updated Branches:
refs/heads/master 5dc624bf8 -> 85b53444a
[FLINK-4564] [metrics] Configurable delimiter per reporter
This closes #2517.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85b53444
Tree: htt
[FLINK-4795] [py] Fix CsvStringify for nested tuples
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af96c077
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/af96c077
Diff: http://git-wip-us.apache.org/repos/asf/flink/
Repository: flink
Updated Branches:
refs/heads/master 6f0faf9bb -> 5c83e787c
[FLINK-4804] [py] Fix first() failing when applied to groupings
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c83e787
Tree: http://git-wip-us.
[FLINK-4794] [py] Fix partition_by_hash() implicit key usage
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/41d51670
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/41d51670
Diff: http://git-wip-us.apache.org/repos/as
[FLINK-4805] [py] Fix implicit type conversion in CsvStringify
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ece925c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ece925c
Diff: http://git-wip-us.apache.org/repos/
Repository: flink
Updated Branches:
refs/heads/master 5c83e787c -> 3ab97ae3d
[FLINK-4784] Unique MetricQueryService actor names
This closes #2636.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3ab97ae3
Tree: http://git-
Repository: flink
Updated Branches:
refs/heads/master 45c3d9b76 -> 3137bf774
[FLINK-4780] Make GraphiteReporter protocol configurable
This closes #2677.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3137bf77
Tree: http:
Repository: flink
Updated Branches:
refs/heads/master 3137bf774 -> 0d2903541
[FLINK-4775] [metrics] Simplify MetricStore access
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0d290354
Tree: http://git-wip-us.apache.org/re
[FLINK-4772] [metrics] Store metrics as strings in MetricStore
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e30e7a61
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e30e7a61
Diff: http://git-wip-us.apache.org/repos/
Repository: flink
Updated Branches:
refs/heads/master 227cdc829 -> b0753f193
[FLINK-4875] [metrics] Use correct operator name
This closes #2676.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0753f19
Tree: http://git-wi
Repository: flink
Updated Branches:
refs/heads/release-1.1 05a5f460b -> dc768d3b7
[FLINK-4875] [metrics] Use correct operator name
This closes #2676.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc768d3b
Tree: http://g
[FLINK-4773] [metrics] [refactor] Rename IOMetricGroup to TaskIOMetricGroup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77258a00
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77258a00
Diff: http://git-wip-us.apac
Repository: flink
Updated Branches:
refs/heads/master c4f9f0d78 -> 022ceb58b
[FLINK-4773] [metrics] [refactor] Introduce OperatorIOMetricGroup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/022ceb58
Tree: http://git-wip-u
Repository: flink
Updated Branches:
refs/heads/master 307eae6e2 -> 1db14fc06
[FLINK-3950] Implement MeterView
This closes #2443.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1db14fc0
Tree: http://git-wip-us.apache.org/
Repository: flink
Updated Branches:
refs/heads/master 3bc9cad04 -> a582882da
[FLINK-4925] [metrics] Integrate meters into IOMetricGroups
This closes #2694.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a582882d
Tree: ht
Repository: flink
Updated Branches:
refs/heads/master 211f5db9d -> 3ce8596b4
[FLINK-4631] Prevent NPE in OneInputStreamTask
This closes #2709.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3ce8596b
Tree: http://git-wip-
Repository: flink
Updated Branches:
refs/heads/master 3ce8596b4 -> 5b54009eb
[FLINK-4544[ Refactor JM/TM metrics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b54009e
Tree: http://git-wip-us.apache.org/repos/asf/flink/t
[hotfix] [metrics] Make JmxMeter class static
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f4be44c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9f4be44c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9f
Repository: flink
Updated Branches:
refs/heads/master 344fe94db -> 9f4be44c2
[FLINK-4245] JMXReporter exposes all defined variables
This closes #2418.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/94d1b63c
Tree: http://
[FLINK-4733] Reuse operator IO metrics for task
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1f4f6f92
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1f4f6f92
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/
[FLINK-4733] Port Task IO metrics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba2d007e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba2d007e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ba2d007e
Bran
http://git-wip-us.apache.org/repos/asf/flink/blob/ba2d007e/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourc
Repository: flink
Updated Branches:
refs/heads/master 094b747a3 -> ba2d007e5
[FLINK-4972] Fix CoordinatorShutdownTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/99f1dc3e
Tree: http://git-wip-us.apache.org/repos/asf/fl
[FLINK-4733] Port TaskManager metrics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf4f3644
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf4f3644
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cf4f3644
[FLINK-4845] [runtime-web] Fix Job Exception page
This closes #2722.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1fea264
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d1fea264
Diff: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master c6c88cec4 -> d1fea2646
[FLINK-4923] [metrics] Initializes all task's gauges in TaskIOMetricGroup and
extract the used buffers interface for BufferPool
This closes #2727.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 1a578657d -> c21ecaed2
[FLINK-5032] Fix CsvOutputFormatTest on Windows OS
This closes #2769.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c21ecaed
Tree: http://git-
[FLINK-5412] Enable RocksDB tests on Windows OS
This closes #3067.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e13ac598
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e13ac598
Diff: http://git-wip-us.apache.org/r
[FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.
This closes #3070.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/71544e96
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/71544e96
Diff: h
Repository: flink
Updated Branches:
refs/heads/master 14bef95b8 -> 6d963642a
[FLINK-4148] Fix min distance calculation in QuadTree
This closes #2442.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e920fcd
Tree: http://g
http://git-wip-us.apache.org/repos/asf/flink/blob/71544e96/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 f94
[FLINK-5381][web-frontend] Fix scrolling issues
This closes #3069.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d963642
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6d963642
Diff: http://git-wip-us.apache.org/r
[FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b93f80af
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b93f80af
Diff: http://git-wip-us.apa
[FLINK-4148] Fix min distance calculation in QuadTree
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d99f2bd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9d99f2bd
Diff: http://git-wip-us.apache.org/repos/asf/flink
[FLINK-5381][web-frontend] Fix scrolling issues
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7251a4ca
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7251a4ca
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/
http://git-wip-us.apache.org/repos/asf/flink/blob/b93f80af/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 f94
[FLINK-5160] SecurityUtils use OperatingSystem.getCurrentOperatingSystem()
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65a32e74
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/65a32e74
Diff: http://git-wip-us.apach
Repository: flink
Updated Branches:
refs/heads/release-1.2 700cbd464 -> 7251a4ca9
[FLINK-5412] Enable RocksDB tests on Windows OS
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aaf96127
Tree: http://git-wip-us.apache.org/
[FLINK-5160] SecurityUtils use OperatingSystem.getCurrentOperatingSystem()
This closes #3066.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ed899d5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ed899d5
Diff: htt
Repository: flink
Updated Branches:
refs/heads/release-1.2 7251a4ca9 -> 7ff59fe7b
[hotfix] RAT - Exclude test snapshots
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ff59fe7
Tree: http://git-wip-us.apache.org/repos/asf/
[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: http://git-wip-us.apache.org/rep
[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/as
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
--- a/docs/fig/slots_parallelis
[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: http://git-wip-us.apache.org/repos/asf/flink/
[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/diff/8cdbe
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
a/flink-tests/src/test/java/org/apache/flink/test/cl
[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: http://git-wip-us.apache.org/
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 e92
[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: http://git-wip-us
[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
[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: http://gi
[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: http://git-wip-
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: refs/hea
[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.
Proj
[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: http://git-wip-
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: http://git-wip-us.apache.org/repos/asf/flink/commi
[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: http://git-wip-us.apache.org/repos
[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: http://git-wip-us.a
[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/
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
+++ b/docs/setup/y
[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://gi
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
+++ b/docs/setup/y
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: http://git-wip
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: refs/hea
[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: http://git-wip-us.apache.org/repos/as
[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: http://git-w
[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/tree/a7437cc
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
a/flink-tests/src/test/java/org/apache/flink/test/cl
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
--- a/docs/fig/slots_parallelis
[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: http://git-wip-us.apache.
[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: http://git-w
[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: http://git-wip
[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: http://git-wip-us.apache.org/repos/
[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
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 e92
[FLINK-5464] [metrics] Ignore metrics that are null
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30419ff4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30419ff4
Diff: http://git-wip-us.apache.org/repos/asf/flink/d
Repository: flink
Updated Branches:
refs/heads/release-1.2 1dfb3e0e2 -> b323f66a6
[FLINK-5298] TM checks that log file exists
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f791024e
Tree: http://git-wip-us.apache.org/repo
[hotfix] Remove unused variable in MetricDumpSerializerTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/61c2f2b7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/61c2f2b7
Diff: http://git-wip-us.apache.org/repos/asf
[FLINK-5464] [metrics] Improve MetricDumpSerialization exception handling
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b323f66a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b323f66a
Diff: http://git-wip-us.apache
[FLINK-5298] TM checks that log file exists
This closes #2974.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8fa8c65
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8fa8c65
Diff: http://git-wip-us.apache.org/repos
[FLINK-5464] [metrics] Improve MetricDumpSerialization exception handling
This closes #3128.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8e85a2d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a8e85a2d
Diff: http
[FLINK-5464] [metrics] Ignore metrics that are null
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77047244
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77047244
Diff: http://git-wip-us.apache.org/repos/asf/flink/d
Repository: flink
Updated Branches:
refs/heads/master da26bdc2e -> a8e85a2d5
[hotfix] Remove unused variable in MetricDumpSerializerTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02d7e4a1
Tree: http://git-wip-us.apac
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bfd3fde [FLINK-21407][docs][formats] Remove MongoDb connector as it
is not supported on DataStream API.
add
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fdb8010 [FLINK-26077][runtime] Support operators send request to
Coordinator and return a response (#18737
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 540d876 [FLINK-26017][runtime] Adds log message to when a job is
marked as dirty
add b64a838 [FLINK-26107
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9bd61e1 [FLINK-24474] Bind Jobmanager and
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6fc4bad [FLINK-26079][state/changelog] Disallow recovery from
non-changelog checkpoints
add c7aa5e5 [FLINK
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 979313a [FLINK-26118][connectors/common] Add support for AsyncSink to
downscale with state. AsyncSinkWriter can be
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new de220ba [FLINK-26187][docs] Chinese docs only
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new 03883eb [FLINK-26187][docs
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from de220ba [FLINK-26187][docs] Chinese docs only redirect for chinese
urls
add ea1fb87 [hotfix][legal] Sort gs
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 965ca2d [FLINK-26014][docs] Add documentation for how to use the
working directory on K8s
add eb245b7 [FLINK
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new c95001a [FLINK-26195][kafka] use
1 - 100 of 6712 matches
Mail list logo