Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-04 Thread via GitHub
LXin96 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1626042961 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplete(l

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-04 Thread via GitHub
LXin96 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1626041619 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplete(l

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-04 Thread via GitHub
danny0405 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1625665630 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplet

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-03 Thread via GitHub
danny0405 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1625240199 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplet

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-03 Thread via GitHub
LXin96 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1624539082 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplete(l

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-02 Thread via GitHub
danny0405 commented on code in PR #11377: URL: https://github.com/apache/hudi/pull/11377#discussion_r1623764919 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java: ## @@ -272,6 +275,28 @@ public void notifyCheckpointComplet

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-01 Thread via GitHub
hudi-bot commented on PR #11377: URL: https://github.com/apache/hudi/pull/11377#issuecomment-2143427283 ## CI report: * 8c5b5a184fa712ef5205a699405ea19597134596 Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=24

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-01 Thread via GitHub
hudi-bot commented on PR #11377: URL: https://github.com/apache/hudi/pull/11377#issuecomment-2143409940 ## CI report: * 8c5b5a184fa712ef5205a699405ea19597134596 Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=24

Re: [PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-01 Thread via GitHub
hudi-bot commented on PR #11377: URL: https://github.com/apache/hudi/pull/11377#issuecomment-2143407661 ## CI report: * 8c5b5a184fa712ef5205a699405ea19597134596 UNKNOWN Bot commands @hudi-bot supports the following commands: - `@hudi-bot run azure` re-run th

[PR] [HUDI-7825]Support Report pending clustering and compaction plan metric [hudi]

2024-06-01 Thread via GitHub
LXin96 opened a new pull request, #11377: URL: https://github.com/apache/hudi/pull/11377 ### Change Logs 1、when just async clustering or async compaction schedule enable, and clustering.async.enabled or compaction.async.enabled set false, then the flink job will not add clust