[GitHub] [inlong] gong commented on a diff in pull request #6931: [INLONG-6925][Sort] Add read phase metric and table level metric for MongoDB-CDC

[GitBox]

gong commented on code in PR #6931:
URL: https://github.com/apache/inlong/pull/6931#discussion_r1054025580


##########
inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/DebeziumSourceFunction.java:
##########
@@ -505,11 +505,11 @@ public void deserialize(SourceRecord record, Collector<T> 
out) throws Exception
                                         source = 
value.getStruct(RecordUtils.DOCUMENT_TO_FIELD);
                                     }
                                     String dbName = 
source.getString(MongoDBEnvelope.NAMESPACE_DATABASE_FIELD);
-                                    String tableName = 
source.getString(MongoDBEnvelope.NAMESPACE_COLLECTION_FIELD);
+                                    String collectionName = 
source.getString(MongoDBEnvelope.NAMESPACE_COLLECTION_FIELD);
                                     SnapshotRecord snapshotRecord = 
SnapshotRecord.fromSource(source);
                                     boolean isSnapshotRecord = 
(SnapshotRecord.TRUE == snapshotRecord);
                                     sourceMetricData
-                                            .outputMetricsWithEstimate(dbName, 
tableName, isSnapshotRecord, value);
+                                            .outputMetricsWithEstimate(dbName, 
collectionName, isSnapshotRecord, value);

Review Comment:
   @kuansix You can pull code and modfiy here after the 
[PR](https://github.com/apache/inlong/pull/7007) is merge



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org