Skip to content

Commit bb803fd

Browse files
[flink] Improve Javadoc wording in OrphanFilesCleanAction
1 parent 879e6cc commit bb803fd

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/action/orphan/OrphanFilesCleanAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@
3232
* OrphanFilesCleanJob}) that executes a 3-stage DAG:
3333
*
3434
* <ol>
35-
* <li>ScopeEnumerator (p=1): coordinator RPCs to enumerate scope and emit work items.
35+
* <li>ScopeEnumerator (p=1): coordinator RPCs to enumerate scope and emit per-bucket work items.
3636
* <li>ScanAndClean (p=N): parallel FS scan + rate-limited delete.
37-
* <li>StatsAggregate (p=1): merge stats.
37+
* <li>StatsAggregate (p=1): merge per-task stats into final summary.
3838
* </ol>
3939
*/
4040
@Internal

0 commit comments

Comments
 (0)