Hi guys,

Gobblin metrics in table gobblin_job_metrics will produce metrics info. as 
follows:
Metric_name                             metric_type                         
metric_value
JOB.job_xxx_1514443993201.bytes         COUNTER                             
8459988
JOB.job_xxx_1514443993201.records       COUNTER                             6
TASK.task_xxx.bytes                     COUNTER                             
8459988
TASK.task_xxx.records                   COUNTER                             6

Same data structure in gobblin_task_metrics.

Who know what's the read info. and what's the write info, why 
'JOB.job_xxx_1514443993201.bytes' 'JOB.job_xxx_1514443993201.records' placed in 
the gobblin_task_metrics(Does it focus tasks)?
Could I get the task record count of reading and writing?

I find code segment to insert it but don't know where to get the original 
values.
// Insert or update job metrics
      if (jobExecutionInfo.hasMetrics()) {
        for (Metric metric : jobExecutionInfo.getMetrics()) {
          boolean insert =
              !existsMetric(connection, 
JOB_METRIC_EXIST_QUERY_STATEMENT_TEMPLATE,  jobExecutionInfo.getJobId(), 
metric);
          updateMetric(connection, insert ? 
JOB_METRIC_INSERT_STATEMENT_TEMPLATE : JOB_METRIC_UPDATE_STATEMENT_TEMPLATE,
              jobExecutionInfo.getJobId(), metric, insert);
        }
      }

Thanks,
Ethan

Reply via email to