@@ -27,7 +27,7 @@ case class SwitchSummaryIndex(s: SparkSession
val allIndices = es.catIndices()
val size = allIndices.filter(a => a.equals(company_summary) || a.equals(person_summary)).size
- if (size < 2) {
+ if (size != 2) {
throw new RuntimeException("target indices is not found !")
}