Sometime Elasticsearch mapping is not created successfully for newly added columns

[pramodShehan5]

After adding cassandra column into cassandra, we are mapping that field in elasticsearch using _mapping api.
Sometimes it is failing.

2021-04-12 03:37:31,932 WARN [elasticsearch[172.17.0.8][masterService#updateTask][T#1]] BytesRestResponse.java:133 build path: /customers/_mapping/customers, params: {index=customers, type=customers} java.lang.NullPointerException: null at org.elasticsearch.index.mapper.MapperService.discoverTableMapping(MapperService.java:311) at org.elasticsearch.index.mapper.DocumentMapperParser.extractMapping(DocumentMapperParser.java:198) at org.elasticsearch.index.mapper.DocumentMapperParser.parse(DocumentMapperParser.java:90) at org.elasticsearch.index.mapper.MapperService.parse(MapperService.java:893) at org.elasticsearch.cluster.metadata.MetaDataMappingService$PutMappingExecutor.applyRequest(MetaDataMappingService.java:317) at org.elasticsearch.cluster.metadata.MetaDataMappingService$PutMappingExecutor.execute(MetaDataMappingService.java:281) at org.elasticsearch.cluster.service.MasterService.executeTasks(MasterService.java:676) at org.elasticsearch.cluster.service.MasterService.calculateTaskOutputs(MasterService.java:300) at org.elasticsearch.cluster.service.MasterService.runTasks(MasterService.java:221) at org.elasticsearch.cluster.service.MasterService$Batcher.run(MasterService.java:152) at org.elasticsearch.cluster.service.TaskBatcher.runIfNotProcessed(TaskBatcher.java:150) at org.elasticsearch.cluster.service.TaskBatcher$BatchedTask.run(TaskBatcher.java:188) at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:573) at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:244) at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)