[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-17 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1072027683 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/BucketHandles.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-16 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1071735088 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java: ## @@ -94,7 +94,7 @@ * FileID to write handle mapping in order to re

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-16 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1071735088 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java: ## @@ -94,7 +94,7 @@ * FileID to write handle mapping in order to re

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-11 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1067712881 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java: ## @@ -94,7 +94,7 @@ * FileID to write handle mapping in order to re

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-10 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1065499424 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java: ## @@ -94,7 +94,7 @@ * FileID to write handle mapping in order to re

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-09 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1065293780 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java: ## @@ -449,6 +450,7 @@ private boolean flushBucket(DataBucket bucket) {

[GitHub] [hudi] trushev commented on a diff in pull request #7626: [HUDI-5516] Reduce memory footprint on workload with thousand active partitions

2023-01-09 Thread GitBox
trushev commented on code in PR #7626: URL: https://github.com/apache/hudi/pull/7626#discussion_r1065294170 ## hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java: ## @@ -94,7 +94,7 @@ * FileID to write handle mapping in order to re