This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new d5ba82b60c7 [HUDI-7196] Call register metric before rollback
compcation (#10268)
d5ba82b60c7 is described below
commit d5ba82b60c77183c6abfdfb897b2d7174135d12b
Author: hehuiyuan <[email protected]>
AuthorDate: Fri Dec 8 11:39:57 2023 +0800
[HUDI-7196] Call register metric before rollback compcation (#10268)
---
.../main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
index bb4ee0a34ac..00591806cc8 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
@@ -72,12 +72,12 @@ public class CompactionPlanOperator extends
AbstractStreamOperator<CompactionPla
@Override
public void open() throws Exception {
super.open();
+ registerMetrics();
this.table = FlinkTables.createTable(conf, getRuntimeContext());
// when starting up, rolls back all the inflight compaction instants if
there exists,
// these instants are in priority for scheduling task because the
compaction instants are
// scheduled from earliest(FIFO sequence).
CompactionUtil.rollbackCompaction(table);
- registerMetrics();
}
@Override
