|
48 | 48 | import org.elasticsearch.common.cache.CacheBuilder; |
49 | 49 | import org.elasticsearch.common.io.stream.BytesStreamOutput; |
50 | 50 | import org.elasticsearch.common.io.stream.InputStreamStreamInput; |
51 | | -import org.elasticsearch.common.io.stream.OutputStreamStreamOutput; |
52 | 51 | import org.elasticsearch.common.io.stream.StreamInput; |
53 | | -import org.elasticsearch.common.io.stream.StreamOutput; |
54 | 52 | import org.elasticsearch.common.settings.SecureString; |
55 | 53 | import org.elasticsearch.common.settings.Setting; |
56 | 54 | import org.elasticsearch.common.settings.Setting.Property; |
|
59 | 57 | import org.elasticsearch.common.util.concurrent.AbstractRunnable; |
60 | 58 | import org.elasticsearch.common.util.concurrent.ThreadContext; |
61 | 59 | import org.elasticsearch.core.Nullable; |
62 | | -import org.elasticsearch.core.Streams; |
63 | 60 | import org.elasticsearch.core.SuppressForbidden; |
64 | 61 | import org.elasticsearch.core.TimeValue; |
65 | 62 | import org.elasticsearch.core.Tuple; |
|
94 | 91 | import org.elasticsearch.xpack.security.support.SecurityIndexManager.IndexState; |
95 | 92 |
|
96 | 93 | import java.io.ByteArrayInputStream; |
97 | | -import java.io.ByteArrayOutputStream; |
98 | 94 | import java.io.Closeable; |
99 | 95 | import java.io.IOException; |
100 | | -import java.io.OutputStream; |
101 | 96 | import java.io.UncheckedIOException; |
102 | 97 | import java.nio.ByteBuffer; |
103 | 98 | import java.nio.charset.StandardCharsets; |
|
134 | 129 |
|
135 | 130 | import javax.crypto.Cipher; |
136 | 131 | import javax.crypto.CipherInputStream; |
137 | | -import javax.crypto.CipherOutputStream; |
138 | 132 | import javax.crypto.NoSuchPaddingException; |
139 | 133 | import javax.crypto.SecretKey; |
140 | 134 | import javax.crypto.SecretKeyFactory; |
@@ -590,7 +584,11 @@ private void getTokenDocById( |
590 | 584 | // if the index or the shard is not there / available we assume that |
591 | 585 | // the token is not valid |
592 | 586 | if (isShardNotAvailableException(e)) { |
593 | | - logger.warn("failed to get token doc [{}] because index [{}] is not available", tokenId, securityTokensIndex.aliasName()); |
| 587 | + logger.warn( |
| 588 | + "failed to get token doc [{}] because index [{}] is not available", |
| 589 | + tokenId, |
| 590 | + securityTokensIndex.aliasName() |
| 591 | + ); |
594 | 592 | } else { |
595 | 593 | logger.error(() -> "failed to get token doc [" + tokenId + "]", e); |
596 | 594 | } |
|
0 commit comments