github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-23 17:28:26 -04:00
Code Issues Projects Releases Packages Wiki Activity

Updated to 0.90.8-SNAP.

Browse source
This commit is contained in:
Boaz Leskes 2013-12-17 13:48:52 +01:00
parent 9c0ecc708e
commit 71757bb330
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
exporter/pom.xml
View file

@ -25,7 +25,7 @@
</parent>
<properties>
<elasticsearch.version>0.90.7</elasticsearch.version>
<elasticsearch.version>0.90.8-SNAPSHOT</elasticsearch.version>
</properties>
<repositories>

6
exporter/src/main/java/org/elasticsearch/marvel/monitor/ExportersService.java
View file

@ -287,7 +287,7 @@ public class ExportersService extends AbstractLifecycleComponent<ExportersServic
RoutingNode oldRoutingNode = previousRoutingNodes.node(shardRouting.currentNodeId());
boolean changed = true;
if (oldRoutingNode != null) {
for (ShardRouting oldShardRouting : oldRoutingNode.shards()) {
for (ShardRouting oldShardRouting : oldRoutingNode) {
if (oldShardRouting.equals(shardRouting)) {
changed = false;
break;
@ -362,7 +362,7 @@ public class ExportersService extends AbstractLifecycleComponent<ExportersServic
class IndicesLifeCycleListener extends IndicesLifecycle.Listener {
@Override
public void indexShardStateChanged(IndexShard indexShard, @Nullable IndexShardState previousState, IndexShardState newState, @Nullable String reason) {
public void indexShardStateChanged(IndexShard indexShard, @Nullable IndexShardState previousState, IndexShardState currentState, @Nullable String reason) {
DiscoveryNode relocatingNode = null;
if (indexShard.routingEntry() != null) {
@ -371,7 +371,7 @@ public class ExportersService extends AbstractLifecycleComponent<ExportersServic
}
}
pendingEventsQueue.add(new ShardEvent(System.currentTimeMillis(), newState,
pendingEventsQueue.add(new ShardEvent(System.currentTimeMillis(), currentState,
indexShard.shardId(), clusterService.localNode(), relocatingNode, indexShard.routingEntry(), reason));
}
}