flink git commit: [FLINK-4122] Disable root shading in Cassandra jar

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:

[5/5] flink git commit: [FLINK-1550] JM JVM Metrics

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

[3/5] flink git commit: [FLINK-456] Basic JM Metric Infrastructure

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

[2/5] flink git commit: [FLINK-4057] Slots/regTaskManagers/numJobs

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

[4/5] flink git commit: [FLINK-4057] Checkpoint Metrics

[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

flink git commit: [hotfix][metrics] Harden JMXAvailability test

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:

[1/2] flink git commit: [FLINK-4411] [py] Properly propagate chained dual input children

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:

flink git commit: [hotfix] [metrics] Refactor constructors and tests

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

[1/2] flink git commit: [FLINK-4411] [py] Properly propagate chained dual input children

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:

[2/2] flink git commit: [FLINK-4412] [py] Chaining properly handles broadcast variables

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

flink git commit: [FLINK-4302] [metrics] Add documentation to MetricConfig

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:

flink git commit: [FLINK-4302] [metrics] Add documentation to MetricConfig

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:

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

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

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

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

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

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

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

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

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

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

[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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[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

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

[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

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

[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

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

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

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

[1/2] flink git commit: [hotfix] [metrics] Rename host format constant

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:

[2/2] flink git commit: [FLINK-4245] Expose all defined variables

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

[2/4] flink git commit: [FLINK-5852] Move handler JSON generation code into static methods

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

[1/4] flink git commit: [FLINK-5852] Move handler JSON generation code into static methods

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

[4/4] flink git commit: [FLINK-5870] Handlers define REST URLs

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

[3/4] flink git commit: [FLINK-5870] Handlers define REST URLs

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

flink git commit: [FLINK-5948] Fix error in Python zip_with_index documentation

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:

[2/2] flink git commit: [FLINK-4595] Close FileOutputStream in ParameterTool

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

[1/2] flink git commit: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor()

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:

[3/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend

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

[4/4] flink git commit: [hotfix] [metrics] Add missing @Internal annotations

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

[2/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend

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

[1/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend

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

[4/4] flink git commit: [FLINK-4607] Close FileInputStream in ParameterTool and other

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

[1/4] flink git commit: [FLINK-4626] Add missing break in MEtricStore#add()

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:

[2/4] flink git commit: [FLINK-4612] Close FileWriter using try with resources

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

[3/4] flink git commit: [FLINK-4608] Use short-circuit AND in Max/Min AggregationFunction

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

flink git commit: [FLINK-4622] Include 'savepoint' in the CLI help message

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:

flink git commit: [FLINK-3950] Add Meter interface

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:

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:

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:

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:

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

[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

[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

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:

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

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

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:

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:

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:

flink git commit: [FLINK-4939] WriteAheadSink: Decouple creation and commit of a pending checkpoint

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

flink git commit: [FLINK-4177] Harden CassandraConnectorITCase

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:

flink git commit: [hotfix] [cassandra] Fix CassandraSinkBase serialization issue

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:

[2/2] flink git commit: [hotfix] [metrics] Prevent concurrency issues in MeterView

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

[1/2] flink git commit: [hotfix] [metrics] Supply name to view/reporter thread

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:

[2/4] flink git commit: [FLINK-5112] [ExecutionGraph] Remove unused accumulator aggregation code from ArchivedExecutionJobVertex

[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

[4/4] flink git commit: [FLINK-5096] Make the RollingSink rescalable.

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

[3/4] flink git commit: [FLINK-4741] Proper shutdown the ServerBootstrap WebRuntimeMonitor

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

[1/4] flink git commit: [hotfix] Fix condition in CoGroupRawDescriptor

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:

flink git commit: [hotfix] [metrics] MetricRegistry threadNumber starts at 1

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:

flink git commit: [FLINK-5054] [FLINK-5056] Make the BucketingSink rescalable.

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

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

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

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

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

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:

<    1   2   3   4   5   6   7   8   9   10   >