Closed mrdlmndr closed 9 years ago
Hi,
I am unable to get Kinesis shard list in ZookeeperStateManager - activate() function in remote Mode.
Not able to getShardList in below line code: ImmutableList shardList = ImmutableList.copyOf(shardListGetter.getShardList().keySet());
The last log which I got: 5815 [Thread-11-kinesis_spout] INFO com.amazonaws.services.kinesis.stormspout.KinesisHelper - Using us-west-1 region
It works fine in case of LocalMode.
Hi,
I am unable to get Kinesis shard list in ZookeeperStateManager - activate() function in remote Mode.
Not able to getShardList in below line code: ImmutableList shardList = ImmutableList.copyOf(shardListGetter.getShardList().keySet());
The last log which I got: 5815 [Thread-11-kinesis_spout] INFO com.amazonaws.services.kinesis.stormspout.KinesisHelper - Using us-west-1 region
It works fine in case of LocalMode.