Changed NAME_TEMPLATE
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/bfffc5f7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/bfffc5f7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/bfffc5f7 Branch: refs/heads/master Commit: bfffc5f7261b9117dd33bab7259e95e6de1f5e26 Parents: d305371 Author: Ryan Ebanks <[email protected]> Authored: Mon Oct 20 15:32:13 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Mon Oct 20 15:32:13 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/streams/local/counters/StreamsTaskCounter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/bfffc5f7/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java index a0eb349..c93cae9 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java @@ -32,7 +32,7 @@ import java.util.concurrent.atomic.AtomicLong; @ThreadSafe public class StreamsTaskCounter implements StreamsTaskCounterMXBean{ - public static final String NAME_TEMPLATE = "org.apache.streams.local:type=DatumCounter,name=%s"; + public static final String NAME_TEMPLATE = "org.apache.streams.local:type=StreamsTaskCounter,name=%s"; private static final Logger LOGGER = LoggerFactory.getLogger(StreamsTaskCounter.class); private AtomicLong emitted;
