[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r754835223 ## File path: hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java ## @@ -105,6 +111,16 @@ public String

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r754834979 ## File path: hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java ## @@ -59,15 +69,15 @@ public static final

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r754834833 ## File path: hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java ## @@ -206,11

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r754834527 ## File path: hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java ## @@ -54,15 +55,20 @@ private final

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r753972409 ## File path: hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaExecutionStrategy.java ## @@ -0,0 +1,245 @@ +/* +

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r752819581 ## File path: hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java ## @@ -59,15 +69,15 @@ public static final

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r749735457 ## File path: hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java ## @@ -206,11

[GitHub] [hudi] yihua commented on a change in pull request #3857: [HUDI-2332] Add clustering and compaction in Kafka Connect Sink

yihua commented on a change in pull request #3857: URL: https://github.com/apache/hudi/pull/3857#discussion_r749716962 ## File path: hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaExecutionStrategy.java ## @@ -0,0 +1,245 @@ +/* +