@@ -134,25 +134,10 @@ public static boolean checkTemplateExistsAndVersionIsGTECurrentVersion(String te
134134 * @param templateName Name of the index template
135135 * @param state Cluster state
136136 * @param logger Logger
137- * @param versionComposableTemplateExpected In which version of Elasticsearch did this template switch to being a composable template?
138- * <code>null</code> means the template hasn't been switched yet.
139137 */
140- public static boolean checkTemplateExistsAndIsUpToDate (
141- String templateName ,
142- String versionKey ,
143- ClusterState state ,
144- Logger logger ,
145- Version versionComposableTemplateExpected
146- ) {
138+ public static boolean checkTemplateExistsAndIsUpToDate (String templateName , String versionKey , ClusterState state , Logger logger ) {
147139
148- return checkTemplateExistsAndVersionMatches (
149- templateName ,
150- versionKey ,
151- state ,
152- logger ,
153- Version .CURRENT ::equals ,
154- versionComposableTemplateExpected
155- );
140+ return checkTemplateExistsAndVersionMatches (templateName , versionKey , state , logger , Version .CURRENT ::equals );
156141 }
157142
158143 /**
@@ -162,32 +147,20 @@ public static boolean checkTemplateExistsAndIsUpToDate(
162147 * @param state Cluster state
163148 * @param logger Logger
164149 * @param predicate Predicate to execute on version check
165- * @param versionComposableTemplateExpected In which version of Elasticsearch did this template switch to being a composable template?
166- * <code>null</code> means the template hasn't been switched yet.
167150 */
168151 public static boolean checkTemplateExistsAndVersionMatches (
169152 String templateName ,
170153 String versionKey ,
171154 ClusterState state ,
172155 Logger logger ,
173- Predicate <Version > predicate ,
174- Version versionComposableTemplateExpected
156+ Predicate <Version > predicate
175157 ) {
176158
177- CompressedXContent mappings ;
178- if (versionComposableTemplateExpected != null && state .nodes ().getMinNodeVersion ().onOrAfter (versionComposableTemplateExpected )) {
179- ComposableIndexTemplate templateMeta = state .metadata ().templatesV2 ().get (templateName );
180- if (templateMeta == null ) {
181- return false ;
182- }
183- mappings = templateMeta .template ().mappings ();
184- } else {
185- IndexTemplateMetadata templateMeta = state .metadata ().templates ().get (templateName );
186- if (templateMeta == null ) {
187- return false ;
188- }
189- mappings = templateMeta .getMappings ();
159+ IndexTemplateMetadata templateMeta = state .metadata ().templates ().get (templateName );
160+ if (templateMeta == null ) {
161+ return false ;
190162 }
163+ CompressedXContent mappings = templateMeta .getMappings ();
191164
192165 // check all mappings contain correct version in _meta
193166 // we have to parse the source here which is annoying
0 commit comments