4849505152535455565758
@Override public void start() { PollableSink sink = (PollableSink) getSink(); sink.start(); runner = new PollingRunner(); runner.sink = sink; runner.counterGroup = counterGroup;