[GitHub] [hadoop] lfxy commented on a diff in pull request #5143: HDFS-16846. EC: Only EC blocks should be effected by max-streams-hard-limit configuration

lfxy commented on code in PR #5143: URL: https://github.com/apache/hadoop/pull/5143#discussion_r1033554982 ## hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestDatanodeManager.java: ## @@ -1040,28 +1054,28 @@ private void

[GitHub] [hadoop] lfxy commented on a diff in pull request #5143: HDFS-16846. EC: Only EC blocks should be effected by max-streams-hard-limit configuration

lfxy commented on code in PR #5143: URL: https://github.com/apache/hadoop/pull/5143#discussion_r1033551972 ## hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestDatanodeManager.java: ## @@ -1009,13 +1011,25 @@ private void

[GitHub] [hadoop] lfxy commented on a diff in pull request #5143: HDFS-16846. EC: Only EC blocks should be effected by max-streams-hard-limit configuration

lfxy commented on code in PR #5143: URL: https://github.com/apache/hadoop/pull/5143#discussion_r1032740002 ## hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java: ## @@ -197,6 +197,9 @@ public Type getType() {

[GitHub] [hadoop] lfxy commented on a diff in pull request #5143: HDFS-16846. EC: Only EC blocks should be effected by max-streams-hard-limit configuration

lfxy commented on code in PR #5143: URL: https://github.com/apache/hadoop/pull/5143#discussion_r1032739866 ## hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java: ## @@ -678,6 +682,16 @@ public void

[GitHub] [hadoop] lfxy commented on a diff in pull request #5143: HDFS-16846. EC: Only EC blocks should be effected by max-streams-hard-limit configuration

lfxy commented on code in PR #5143: URL: https://github.com/apache/hadoop/pull/5143#discussion_r1032739690 ## hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java: ## @@ -1825,28 +1825,48 @@ public DatanodeCommand[]