gosonzhang commented on code in PR #8085:
URL: https://github.com/apache/inlong/pull/8085#discussion_r1204958891
##########
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/CommonConfigHolder.java:
##########
@@ -75,6 +75,17 @@ public class CommonConfigHolder {
// whether enable whitelist, optional field.
public static final String KEY_ENABLE_WHITELIST = "proxy.enable.whitelist";
public static final boolean VAL_DEF_ENABLE_WHITELIST = false;
+ // whether enable file metric, optional field.
+ public static final String KEY_ENABLE_FILEMETRIC = "filemetric.enable";
Review Comment:
done
##########
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/SinkContext.java:
##########
@@ -80,6 +85,16 @@ public SinkContext(String sinkName, Context context, Channel
channel) {
* start
*/
public void start() {
+ // init monitor logic
+ if (CommonConfigHolder.getInstance().isEnableFileMetric()) {
+ this.monitorIndex = new MonitorIndex("Sink",
Review Comment:
done
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
