flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzulitai <...@git.apache.org>
Subject [GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...
Date Thu, 11 Jan 2018 01:02:25 GMT
Github user tzulitai commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5182#discussion_r160841254
  
    --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
    @@ -542,6 +545,16 @@ public int registerNewSubscribedShardState(KinesisStreamShardState
newSubscribed
     		}
     	}
     
    +	/**
    +	 * Registers a metric group associated with the shard id of the provided {@link KinesisStreamShardState
shardState}.
    +	 */
    +	private MetricGroup registerMetricGroupForShard(KinesisStreamShardState shardState)
{
    +		return runtimeContext
    +			.getMetricGroup()
    +			.addGroup("Kinesis")
    +			.addGroup("shardId", shardState.getStreamShardHandle().getShard().getShardId());
    --- End diff --
    
    We probably should also add a `stream` group before `shardId`, since the Kinesis consumer
allows subscribing to multiple streams.


---

Mime
View raw message