[hotfix] Fix raw types warning.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f34a851 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f34a851 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0f34a851 Branch: refs/heads/release-1.5 Commit: 0f34a851daa4e479a3faa1dfd97e28eff52b89ab Parents: 3220909 Author: gyao <[email protected]> Authored: Thu Apr 19 11:05:05 2018 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Apr 30 23:25:06 2018 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/yarn/YarnResourceManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0f34a851/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---------------------------------------------------------------------- diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java index a25e4c4..220f4f2 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java @@ -435,7 +435,7 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme String[] hostPort = address.split("@")[1].split(":"); String host = hostPort[0]; String port = hostPort[1].split("/")[0]; - return new Tuple2(host, Integer.valueOf(port)); + return new Tuple2<>(host, Integer.valueOf(port)); } private void requestYarnContainer(Resource resource, Priority priority) {
