Skip to main content
Version: v1.6.x

Monitoring: SeaTunnel

Collect monitoring metrics for SeaTunnel.

Configuration Parameters

Parameter NameParameter Help Description
Target HostThe monitored endpoint's IPV4, IPV6, or domain name. Note ⚠️ no protocol header (e.g., https://, http://).
Task NameThe name that identifies this monitoring task, which needs to be unique.
PortThe monitoring port opened by SeaTunnel, default value: 5801.
SSLWhether SSL is enabled for connecting to SeaTunnel.
Query TimeoutSet the timeout for unresponsive queries, in milliseconds (ms), default 6000 ms.
Collection IntervalThe interval time for periodic data collection, in seconds; the minimum interval that can be set is 30 seconds.
Binding TagsUsed for categorizing and managing monitoring resources.
Description NotesAdditional identification and description notes for this monitoring; users can add notes here.

Collected Metrics

Metric Set: Cluster Overview

Metric NameMetric UnitMetric Help Description
projectVersionNoneProject version
gitCommitAbbrevNoneGit commit hash
totalSlotNoneTotal number of slots
unassignedSlotNoneNumber of unassigned slots
runningJobsNoneNumber of running tasks
finishedJobsNoneNumber of completed tasks
failedJobsNoneNumber of failed tasks
cancelledJobsNoneNumber of cancelled tasks
workersNoneNumber of workers

Metric Set: Thread Information

Metric NameMetric UnitMetric Help Description
threadNameNoneThread name
threadIdNoneThread ID
threadStateNoneThread state
stackTraceNoneStack trace information

Metric Set: Node Monitoring

Metric NameMetric UnitMetric Help Description
isMasterNoneWhether it is a master node
hostNoneIP address
portNonePort
processorsNoneNumber of processors
physical.memory.totalNoneTotal physical memory
physical.memory.freeNoneAvailable physical memory
swap.space.totalNoneTotal swap space
swap.space.freeNoneAvailable swap space
heap.memory.usedNoneUsed heap memory
heap.memory.freeNoneAvailable heap memory
heap.memory.totalNoneTotal heap memory
heap.memory.maxNoneMaximum heap memory
heap.memory.used/totalNoneHeap memory usage rate
heap.memory.used/maxNoneMaximum heap memory usage rate
minor.gc.countNoneMinor garbage collection count
minor.gc.timeNoneMinor garbage collection time
major.gc.countNoneMajor garbage collection count
major.gc.timeNoneMajor garbage collection time
load.processNoneProcess load
load.systemNoneSystem load
load.systemAverageNoneAverage system load
thread.countNoneNumber of threads
thread.peakCountNonePeak thread count
cluster.timeDiffNoneCluster time difference
event.q.sizeNoneEvent queue size
executor.q.async.sizeNoneAsynchronous execution queue size
executor.q.client.sizeNoneClient execution queue size
executor.q.client.query.sizeNoneClient query queue size
executor.q.client.blocking.sizeNoneClient blocking queue size
executor.q.query.sizeNoneQuery queue size
executor.q.scheduled.sizeNoneScheduled execution queue size
executor.q.io.sizeNoneIO queue size
executor.q.system.sizeNoneSystem execution queue size
executor.q.operations.sizeNoneOperations queue size
executor.q.priorityOperation.sizeNonePriority operations queue size
operations.completed.countNoneCompleted operations count
executor.q.mapLoad.sizeNoneMap load queue size
executor.q.mapLoadAllKeys.sizeNoneMap load all keys size
executor.q.cluster.sizeNoneCluster execution queue size
executor.q.response.sizeNoneResponse queue size
operations.running.countNoneNumber of running operations
operations.pending.invocations.percentageNonePercentage of pending invocations
operations.pending.invocations.countNoneNumber of pending invocations
proxy.countNoneNumber of proxies
clientEndpoint.countNoneNumber of client endpoints
connection.active.countNoneNumber of active connections
client.connection.countNoneNumber of client connections
connection.countNoneTotal number of connections