[2/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph

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

[3/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph

[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

[1/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph

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 ---

flink git commit: [FLINK-4774] [metrics] Fix scope concatenation in QueryScopeInfo

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

flink git commit: [FLINK-4827] [docs] Fix scala Streaming Table example

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

flink git commit: [hotfix] Fix ArchivedExecutionGraphTest

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

flink git commit: [FLINK-4564] [metrics] Configurable delimiter per reporter

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

[4/4] flink git commit: [FLINK-4795] [py] Fix CsvStringify for nested tuples

[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/

[1/4] flink git commit: [FLINK-4804] [py] Fix first() failing when applied to groupings

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.

[3/4] flink git commit: [FLINK-4794] [py] Fix partition_by_hash() implicit key usage

[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

[2/4] flink git commit: [FLINK-4805] [py] Fix implicit type conversion in CsvStringify

[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/

flink git commit: [FLINK-4784] Unique MetricQueryService actor names

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-

flink git commit: [FLINK-4780] Make GraphiteReporter protocol configurable

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:

[1/2] flink git commit: [FLINK-4775] [metrics] Simplify MetricStore access

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

[2/2] flink git commit: [FLINK-4772] [metrics] Store metrics as strings in MetricStore

[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/

flink git commit: [FLINK-4875] [metrics] Use correct operator name

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

flink git commit: [FLINK-4875] [metrics] Use correct operator name

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

[2/2] flink git commit: [FLINK-4773] [metrics] [refactor] Rename IOMetricGroup to TaskIOMetricGroup

[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

[1/2] flink git commit: [FLINK-4773] [metrics] [refactor] Introduce OperatorIOMetricGroup

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

flink git commit: [FLINK-3950] Implement MeterView

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/

flink git commit: [FLINK-4925] [metrics] Integrate meters into IOMetricGroups

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

flink git commit: [FLINK-4631] Prevent NPE in OneInputStreamTask

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-

flink git commit: [FLINK-4544[ Refactor JM/TM metrics

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

[2/2] flink git commit: [hotfix] [metrics] Make JmxMeter class static

[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

[1/2] flink git commit: [FLINK-4245] JMXReporter exposes all defined variables

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://

[2/5] flink git commit: [FLINK-4733] Reuse operator IO metrics for task

[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/

[5/5] flink git commit: [FLINK-4733] Port Task IO metrics

[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

[4/5] flink git commit: [FLINK-4733] Port Task IO metrics

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

[1/5] flink git commit: [FLINK-4972] Fix CoordinatorShutdownTest

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

[3/5] flink git commit: [FLINK-4733] Port TaskManager metrics

[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

[2/2] flink git commit: [FLINK-4845] [runtime-web] Fix Job Exception page

[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

[1/2] flink git commit: [FLINK-4923] [metrics] Initializes all task's gauges in TaskIOMetricGroup and extract the used buffers interface for BufferPool

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:

flink git commit: [FLINK-5032] Fix CsvOutputFormatTest on Windows OS

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-

[2/6] flink git commit: [FLINK-5412] Enable RocksDB tests on Windows OS

[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

[5/6] flink git commit: [FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.

[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

[1/6] flink git commit: [FLINK-4148] Fix min distance calculation in QuadTree

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

[4/6] flink git commit: [FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.

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

[6/6] flink git commit: [FLINK-5381][web-frontend] Fix scrolling issues

[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

[5/6] flink git commit: [FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.

[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

[3/6] flink git commit: [FLINK-4148] Fix min distance calculation in QuadTree

[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

[6/6] flink git commit: [FLINK-5381][web-frontend] Fix scrolling issues

[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/

[4/6] flink git commit: [FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path.

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

[2/6] flink git commit: [FLINK-5160] SecurityUtils use OperatingSystem.getCurrentOperatingSystem()

[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

[1/6] flink git commit: [FLINK-5412] Enable RocksDB tests on Windows OS

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/

[3/6] flink git commit: [FLINK-5160] SecurityUtils use OperatingSystem.getCurrentOperatingSystem()

[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

flink git commit: [hotfix] RAT - Exclude test snapshots

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/

[10/17] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

[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

[04/17] flink git commit: [FLINK-5419] Make full TM metrics available through REST API

[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

[09/17] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

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

[03/17] flink git commit: [FLINK-5150] [webui] Store metrics in sessionStorage

[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/

[06/17] flink git commit: [FLINK-5329] Fix metric list being cut off

[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

[12/17] flink git commit: [FLINK-5113] Port functions in tests to new CheckpointedFunction IF.

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

[15/17] flink git commit: [FLINK-5493] Fix String formats in FlinkDistributionOverlay and Task

[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/

[16/17] flink git commit: Rebuild web-dashboard

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

[10/18] flink git commit: [FLINK-5419] Make full TM metrics available through REST API

[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

[14/18] flink git commit: [FLINK-4920] Introduce Scala Function Gauge

[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

[16/18] flink git commit: [FLINK-5493] Fix String formats in FlinkDistributionOverlay and Task

[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

[04/18] flink git commit: [FLINK-5380] Fix task metrics reuse for single-operator chains

[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-

[17/17] flink git commit: Rebuild web-dashboard

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

[09/18] flink git commit: [FLINK-5424] Improve Restart Strategy Logging

[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

[07/17] flink git commit: [FLINK-5424] Improve Restart Strategy Logging

[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-

[01/18] flink git commit: [FLINK-5432] recursively scan nested files in ContinuousFileMonitoringFunction

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

[11/17] flink git commit: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS

[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

[02/17] flink git commit: [FLINK-5432] recursively scan nested files in ContinuousFileMonitoringFunction

[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

[13/17] flink git commit: [FLINK-5113] Port functions in tests to new CheckpointedFunction IF.

[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/

[06/18] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

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

[13/18] flink git commit: [FLINK-5113] Port functions in tests to new CheckpointedFunction IF.

[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

[08/17] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

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

[01/17] flink git commit: [FLINK-5380] Fix task metrics reuse for single-operator chains

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

[18/18] flink git commit: Rebuild web-dashboard

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

[14/17] flink git commit: [hotfix] [doc] Fix several broken "Linking with Flink" links

[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

[05/17] flink git commit: [FLINK-5434] Remove unsupported project() transformation from Scala DataStream docs.

[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

[03/18] flink git commit: [FLINK-5434] Remove unsupported project() transformation from Scala DataStream docs.

[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

[12/18] flink git commit: [FLINK-5113] Port functions in tests to new CheckpointedFunction IF.

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

[07/18] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

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

[02/18] flink git commit: [FLINK-5150] [webui] Store metrics in sessionStorage

[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.

[08/18] flink git commit: [FLINK-5417] [docs] Fix config file name in slots_parallelism.svg

[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

[11/18] flink git commit: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS

[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

[05/18] flink git commit: [FLINK-5329] Fix metric list being cut off

[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/

[15/18] flink git commit: [hotfix] [doc] Fix several broken "Linking with Flink" links

[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

[17/18] flink git commit: Rebuild web-dashboard

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

[4/4] flink git commit: [FLINK-5464] [metrics] Ignore metrics that are null

[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

[1/4] flink git commit: [FLINK-5298] TM checks that log file exists

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

[2/4] flink git commit: [hotfix] Remove unused variable in MetricDumpSerializerTest

[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

[3/4] flink git commit: [FLINK-5464] [metrics] Improve MetricDumpSerialization exception handling

[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

[2/4] flink git commit: [FLINK-5298] TM checks that log file exists

[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

[4/4] flink git commit: [FLINK-5464] [metrics] Improve MetricDumpSerialization exception handling

[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

[3/4] flink git commit: [FLINK-5464] [metrics] Ignore metrics that are null

[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

[1/4] flink git commit: [hotfix] Remove unused variable in MetricDumpSerializerTest

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

[flink] branch master updated (bfd3fde -> 0cf7c3d)

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

[flink] branch master updated (fdb8010 -> 6222532)

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

[flink] branch master updated (540d876 -> b64a838)

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

[flink] branch master updated: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

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

[flink] branch master updated (6fc4bad -> c7aa5e5)

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

[flink] branch master updated (979313a -> c865def)

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

[flink] branch master updated: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

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

[flink] branch release-1.14 updated: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

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

[flink] branch master updated (de220ba -> 54b21e8)

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

[flink] branch master updated (965ca2d -> eb245b7)

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

[flink] branch master updated: [FLINK-26195][kafka] use TestLoggerExtension in JUnit5 tests

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   2   3   4   5   6   7   8   9   10   >