From c85b1f42b7fb0cb7bdf59e919a756277f44b65df Mon Sep 17 00:00:00 2001 From: Qilin Jin Date: Thu, 2 Dec 2021 10:41:05 -0800 Subject: [PATCH] change operation name for the new metric --- .../java/software/amazon/kinesis/lifecycle/ProcessTask.java | 4 ++-- .../test/java/software/amazon/kinesis/ApplicationTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java index bd3b9721..b1f6121c 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java @@ -45,7 +45,7 @@ import software.amazon.kinesis.schemaregistry.SchemaRegistryDecoder; @KinesisClientInternalApi public class ProcessTask implements ConsumerTask { private static final String PROCESS_TASK_OPERATION = "ProcessTask"; - private static final String APPLICATION_LEVEL_METRICS = "ApplicationLevelMetrics"; + private static final String APPLICATION_TRACKER_OPERATION = "ApplicationTracker"; private static final String DATA_BYTES_PROCESSED_METRIC = "DataBytesProcessed"; private static final String RECORDS_PROCESSED_METRIC = "RecordsProcessed"; private static final String RECORD_PROCESSOR_PROCESS_RECORDS_METRIC = "RecordProcessor.processRecords"; @@ -113,7 +113,7 @@ public class ProcessTask implements ConsumerTask { */ @Override public TaskResult call() { - final MetricsScope scope_app = MetricsUtil.createMetricsWithOperation(metricsFactory, APPLICATION_LEVEL_METRICS); + final MetricsScope scope_app = MetricsUtil.createMetricsWithOperation(metricsFactory, APPLICATION_TRACKER_OPERATION); final MetricsScope scope_shard = MetricsUtil.createMetricsWithOperation(metricsFactory, PROCESS_TASK_OPERATION); shardInfo.streamIdentifierSerOpt() .ifPresent(streamId -> MetricsUtil.addStreamId(scope_shard, StreamIdentifier.multiStreamInstance(streamId))); diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/ApplicationTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/ApplicationTest.java index 32d228ef..e3616ff0 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/ApplicationTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/ApplicationTest.java @@ -52,7 +52,7 @@ public class ApplicationTest { String streamName1 = "consumer-level-metrics-1"; String streamName2 = "consumer-level-metrics-2"; String region = "us-east-2"; - String applicationName = "consumer-level-metrics-test"; + String applicationName = "consumer-level-metrics-test-new"; new ApplicationTest(applicationName, streamName1, streamName2, region).run(); }