Using correct default shard prioritization strategy.
* Fixing bug where this was set as default in configuration, but if a configuraiton is not specified it falls back to parent prioritization.
This commit is contained in:
parent
bb84c17abf
commit
66bcd45d36
1 changed files with 1 additions and 1 deletions
|
|
@ -1469,7 +1469,7 @@ public class Worker implements Runnable {
|
||||||
}
|
}
|
||||||
|
|
||||||
if (shardPrioritization == null) {
|
if (shardPrioritization == null) {
|
||||||
shardPrioritization = new ParentsFirstShardPrioritization(1);
|
shardPrioritization = new NoOpShardPrioritization();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (kinesisProxy == null) {
|
if (kinesisProxy == null) {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue