apache/seatunnel

[Bug][Core][Metric] sinkwritecount miscalculation: duplicate table names cause repeated counting

Open

#10248 opened on Dec 25, 2025

View on GitHub
 (4 comments) (0 reactions) (1 assignee)Java (6,897 stars) (1,432 forks)batch import
help wanted

Description

Search before asking

  • I had searched in the feature and found no similar feature requirement.

Description

当有多个sink并且表名相同(table_name)的时候, 统计数据中sinkwritecount会重复计算, 比如sink一个是kafka一个是es,一个是mysql, 表名相同的情况下,source读到1条数据, 那么sinkwritecount中就会是 table_name:2, database.table_name:1, 如何把每个sink区分开呢?

Usage Scenario

对存储的数据进行统计

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Contributor guide

Tech stack
java
Domain
backenddata
Issue type
bug
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
half day
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
blocked
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
clear
Prerequisites
JavaSeaTunnel metricsSink configuration
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
45
Research direction
Start by examining the metric calculation logic in the core module, likely in files like `seatunnel core/...Metrics.java`. Look for how `sinkWriteCount` is computed and where duplicate table names might cause double counting. Check the sink identifier usage; the issue suggests multiple sinks share the same table name. Investigate whether the metric key includes only the table name or also a sink identifier. Review recent commits or linked PRs for any relevant changes.