Repository: flink
Updated Branches:
refs/heads/master 4c4a6f19d -> 96590ffaf
[FLINK-4122] Disable root shading in Cassandra jar
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/96590ffa
Tree:
[FLINK-1550] JM JVM Metrics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fafb9817
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fafb9817
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fafb9817
Branch:
[FLINK-456] Basic JM Metric Infrastructure
This closes #2146
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3a9fd11
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3a9fd11
Diff:
[FLINK-4057] Slots/regTaskManagers/numJobs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8829f973
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8829f973
Diff:
[FLINK-4057] Checkpoint Metrics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9e540daf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9e540daf
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9e540daf
Repository: flink
Updated Branches:
refs/heads/master 123be2276 -> 53630da01
[hotfix][metrics] Harden JMXAvailability test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53630da0
Tree:
Repository: flink
Updated Branches:
refs/heads/master b19648eb4 -> 84d28ba00
[FLINK-4411] [py] Properly propagate chained dual input children
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/10508477
Tree:
Repository: flink
Updated Branches:
refs/heads/master 84d28ba00 -> c8f5745f2
[hotfix] [metrics] Refactor constructors and tests
- removed constructors taking a specific ScopeFormat as argument, as
they were only used by tests and serve no real purpose
- refactored tests accordingly
- made
Repository: flink
Updated Branches:
refs/heads/release-1.1 c2906c021 -> 445eaa986
[FLINK-4411] [py] Properly propagate chained dual input children
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aa50e226
Tree:
[FLINK-4412] [py] Chaining properly handles broadcast variables
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/445eaa98
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/445eaa98
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.1 445eaa986 -> cbce10d10
[FLINK-4302] [metrics] Add documentation to MetricConfig
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cbce10d1
Tree:
Repository: flink
Updated Branches:
refs/heads/master c8f5745f2 -> c5a9a3eb0
[FLINK-4302] [metrics] Add documentation to MetricConfig
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c5a9a3eb
Tree:
[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:
[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:
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:
[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:
[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:
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:
[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-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-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:
[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:
[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-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:
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-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-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-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/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-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-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:
Repository: flink
Updated Branches:
refs/heads/master 59eb4332f -> ebda2e0ea
[hotfix] [metrics] Rename host format constant
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebda2e0e
Tree:
[FLINK-4245] Expose all defined variables
This closes #2300.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cbbd8003
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cbbd8003
Diff:
[FLINK-5852] Move handler JSON generation code into static methods
This closes #3365.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a552d674
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a552d674
Diff:
Repository: flink
Updated Branches:
refs/heads/master 51b7ede28 -> a552d6746
http://git-wip-us.apache.org/repos/asf/flink/blob/a552d674/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/SubtaskExecutionAttemptDetailsHandlerTest.java
[FLINK-5870] Handlers define REST URLs
This closes #3376.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/999bacef
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/999bacef
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/999bacef/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHandlerTest.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 5c968563d -> 82047f723
[FLINK-5948] Fix error in Python zip_with_index documentation
This closes #3454.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82047f72
Tree:
[FLINK-4595] Close FileOutputStream in ParameterTool
This closes #2478
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/920cda40
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/920cda40
Diff:
Repository: flink
Updated Branches:
refs/heads/master 66d4b8724 -> 920cda408
[FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor()
This closes #2402
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e07bde8
Tree:
[FLINK-4389] Expose metrics to WebFrontend
This closes #2363
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70704de0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/70704de0
Diff:
[hotfix] [metrics] Add missing @Internal annotations
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0492dcc8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0492dcc8
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/70704de0/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricDumpSerialization.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 545b72bee -> 0492dcc8e
http://git-wip-us.apache.org/repos/asf/flink/blob/70704de0/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
[FLINK-4607] Close FileInputStream in ParameterTool and other
This closes #2488.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db90580f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db90580f
Diff:
Repository: flink
Updated Branches:
refs/heads/master 7143a2454 -> db90580ff
[FLINK-4626] Add missing break in MEtricStore#add()
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1586fc8c
Tree:
[FLINK-4612] Close FileWriter using try with resources
This closes #2492.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f06930bc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f06930bc
Diff:
[FLINK-4608] Use short-circuit AND in Max/Min AggregationFunction
This closes #2489.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9046374c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9046374c
Diff:
Repository: flink
Updated Branches:
refs/heads/master db90580ff -> d7b59d761
[FLINK-4622] Include 'savepoint' in the CLI help message
This closes #2501.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d7b59d76
Tree:
Repository: flink
Updated Branches:
refs/heads/master 6226108e8 -> 8195001bb
[FLINK-3950] Add Meter interface
This closes #2374
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8195001b
Tree:
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:
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:
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:
[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:
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
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
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:
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:
[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:
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:
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:
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:
Repository: flink
Updated Branches:
refs/heads/master b2e8792b8 -> 381bf5912
[FLINK-4939] WriteAheadSink: Decouple creation and commit of a pending
checkpoint
So far the GenericWriteAheadSink expected that
the subtask that wrote a temporary buffer to the
state backend, will be also the one
Repository: flink
Updated Branches:
refs/heads/master 381bf5912 -> 62523acbe
[FLINK-4177] Harden CassandraConnectorITCase
This closes #2484.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/62523acb
Tree:
Repository: flink
Updated Branches:
refs/heads/master 62523acbe -> 5fa389014
[hotfix] [cassandra] Fix CassandraSinkBase serialization issue
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fa38901
Tree:
[hotfix] [metrics] Prevent concurrency issues in MeterView
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/62192c78
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/62192c78
Diff:
Repository: flink
Updated Branches:
refs/heads/master 5fa389014 -> 62192c783
[hotfix] [metrics] Supply name to view/reporter thread
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57208e65
Tree:
[FLINK-5112] [ExecutionGraph] Remove unused accumulator aggregation code from
ArchivedExecutionJobVertex
The ArchivedExecutionJobVertex calculated for its ExecutionVertices the
aggregated accumulator
value. However, the result was nowhere stored. This indicates that this code is
no longer used
[FLINK-5096] Make the RollingSink rescalable.
Integrates the RollingSink with the new state abstractions so
that its parallelism can change after resuming execution from
a savepoint.
This closes #2845.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4741] Proper shutdown the ServerBootstrap WebRuntimeMonitor
This closes #2862.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/333da3ac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/333da3ac
Diff:
Repository: flink
Updated Branches:
refs/heads/master 1b2f3c06d -> e2b93f69c
[hotfix] Fix condition in CoGroupRawDescriptor
This closes #2852.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7d34f654
Tree:
Repository: flink
Updated Branches:
refs/heads/master 53aae50e5 -> 611412c6b
[hotfix] [metrics] MetricRegistry threadNumber starts at 1
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/611412c6
Tree:
Repository: flink
Updated Branches:
refs/heads/master a67d3f80c -> 13ebb36bb
[FLINK-5054] [FLINK-5056] Make the BucketingSink rescalable.
Refactors the BucketingSink to be able to change
parallelism after restoring from a savepoint. To
do so, this commit changes the following:
1) the sink
[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:
[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:
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:
[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:
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:
101 - 200 of 6473 matches
Mail list logo