Repository: flink Updated Branches: refs/heads/master 2479ff53c -> d45ed2972
[hotfix][tests] Fix compiler warning in MetricFetcherTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/312fb8d6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/312fb8d6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/312fb8d6 Branch: refs/heads/master Commit: 312fb8d672bd084240a914b9ad276e79ff0020cc Parents: 2479ff5 Author: zentol <[email protected]> Authored: Tue Feb 6 14:24:36 2018 +0100 Committer: zentol <[email protected]> Committed: Wed Feb 7 11:42:33 2018 +0100 ---------------------------------------------------------------------- .../runtime/rest/handler/legacy/metrics/MetricFetcherTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/312fb8d6/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java index e5f1bd0..da8182a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java @@ -108,7 +108,7 @@ public class MetricFetcherTest extends TestLogger { when(queryServiceRetriever.retrieveService(eq(tmMetricQueryServicePath))).thenReturn(CompletableFuture.completedFuture(tmQueryService)); // ========= start MetricFetcher testing ======================================================================= - MetricFetcher fetcher = new MetricFetcher( + MetricFetcher fetcher = new MetricFetcher<>( retriever, queryServiceRetriever, Executors.directExecutor(),
