[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r677287722 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -49,6 +51,9 @@ private transient FileSystem fs;

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r675270701 ## File path: hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieDeltaStreamer.java ## @@ -449,6 +451,14 @@ static void assertA

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r675270601 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -164,11 +196,37 @@ private int doCluster(JavaSparkCo

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r675268621 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,29 @@ public static void main(String[]

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r675267730 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -49,6 +51,9 @@ private transient FileSystem fs;

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r672888552 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,26 @@ public static void main(String[]

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r672888552 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,26 @@ public static void main(String[]

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r672894516 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -171,4 +200,38 @@ private int doCluster(JavaSparkCon

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r672888552 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,26 @@ public static void main(String[]

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r669542580 ## File path: hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieDeltaStreamer.java ## @@ -1059,6 +1059,50 @@ public void testH

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r669540279 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -171,4 +200,38 @@ private int doCluster(JavaSparkCon

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r669537910 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -171,4 +200,38 @@ private int doCluster(JavaSparkCon

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r669537132 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,26 @@ public static void main(String[]

[GitHub] [hudi] lw309637554 commented on a change in pull request #3259: [HUDI-2164] Let users build cluster plan and execute this plan at once using HoodieClusteringJob for async clustering

lw309637554 commented on a change in pull request #3259: URL: https://github.com/apache/hudi/pull/3259#discussion_r669536894 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java ## @@ -121,17 +141,26 @@ public static void main(String[]