49
49
import org .elasticsearch .index .shard .IndexShard ;
50
50
import org .elasticsearch .index .shard .ShardId ;
51
51
import org .elasticsearch .indices .IndicesService ;
52
- import org .elasticsearch .tasks .Task ;
53
52
import org .elasticsearch .threadpool .ThreadPool ;
54
53
import org .elasticsearch .transport .TransportService ;
55
54
@@ -194,8 +193,8 @@ protected FieldStatsShardResponse newShardResponse() {
194
193
return new FieldStatsShardResponse ();
195
194
}
196
195
197
- @ Override protected FieldStatsShardResponse shardOperation ( FieldStatsShardRequest request , Task task )
198
- throws IOException {
196
+
197
+ @ Override protected FieldStatsShardResponse shardOperation ( FieldStatsShardRequest request ) throws IOException {
199
198
ShardId shardId = request .shardId ();
200
199
Map <String , FieldStats <?>> fieldStats = new HashMap <>();
201
200
IndexService indexServices = indicesService .indexServiceSafe (shardId .getIndex ());
@@ -204,7 +203,7 @@ protected FieldStatsShardResponse newShardResponse() {
204
203
// Resolve patterns and deduplicate
205
204
Set <String > fieldNames = new HashSet <>();
206
205
for (String field : request .getFields ()) {
207
- fieldNames .addAll (shard .mapperService ().simpleMatchToFullName (field ));
206
+ fieldNames .addAll (shard .mapperService ().simpleMatchToIndexNames (field ));
208
207
}
209
208
for (String field : fieldNames ) {
210
209
FieldStats <?> stats = getFieldStats (shard , searcher , field );
0 commit comments