You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/05/02 09:29:44 UTC
[06/16] flink git commit: [hotfix] Fix raw types warning.
[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 <ga...@data-artisans.com>
Authored: Thu Apr 19 11:05:05 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
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) {