This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 22f9ebc219 [INLONG-8578][Sort] Fix npe inside outputReadPhaseMetrics
in mysql-cdc (#8579)
22f9ebc219 is described below
commit 22f9ebc2199f633c2263d48c590cf5f5d3840c20
Author: Sting <[email protected]>
AuthorDate: Thu Jul 20 12:53:29 2023 +0800
[INLONG-8578][Sort] Fix npe inside outputReadPhaseMetrics in mysql-cdc
(#8579)
---
.../sort/cdc/mysql/source/metrics/MySqlSourceReaderMetrics.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/metrics/MySqlSourceReaderMetrics.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/metrics/MySqlSourceReaderMetrics.java
index 361c79c33a..c59b3286c2 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/metrics/MySqlSourceReaderMetrics.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/metrics/MySqlSourceReaderMetrics.java
@@ -148,6 +148,8 @@ public class MySqlSourceReaderMetrics {
* @param readPhase the readPhase of record
*/
public void outputReadPhaseMetrics(ReadPhase readPhase) {
- sourceTableMetricData.outputReadPhaseMetrics(readPhase);
+ if (sourceTableMetricData != null) {
+ sourceTableMetricData.outputReadPhaseMetrics(readPhase);
+ }
}
}