Resolved [Failed to execute phase [dfs], all shards failed; shardFailures {[aMJwZw2XRpKQasjGV3jLOw][logger_stage][0]:
RemoteTransportException[[aMJwZw2][127.0.0.1:9300][indices:data/read/search[phase/dfs]]]; nested: QueryPhaseExecutionException[Result window is too large, from + size must be less
than or equal to: [10000] but was [10392]. See the scroll api for a more efficient way to request large data sets. This limit can be set by changing the [index.max_result_window] index
level setting.]; }{[aMJwZw2XRpKQasjGV3jLOw][logger_stage][1]: RemoteTransportException[[aMJwZw2][127.0.0.1:9300][indices:data/read/search[phase/dfs]]];
nested: QueryPhaseExecutionException[Result window is too large, from + size must be less than or equal to: [10000] but was [10392]. See the scroll api for a more efficient way to request
large data sets. This limit can be set by changing the [index.max_result_window] index level setting.]; }
PUT your_index_name/_settings{"max_result_window" : 500000}
{"acknowledged": true}
$ curl -XPUT -H "Content-Type: application/json" https://[YOUR_ELASTICSEARCH_ENDPOINT]:9200/_all/_settings -d '{"index.blocks.read_only_allow_delete": null}'
![Elasticsearch error: cluster_block_exception [FORBIDDEN/12/index read-only / allow delete (api)]](https://blogger.googleusercontent.com/img/b/R29vZ2xl/AVvXsEjKNz33H7_RcsDyn_OZDUT8Wnp0pqrpvxgPFnJxsFr0mBHEiSVTRUPflBoRF5CzziALB1d9cUCjWC-yJsmUBf9bD4zg1L-se-y5LUI3IlCnzByEVw6lDjXvJ-y1xiU9LMkoYgJpoMGWN6aN/s1600/Issue_1.PNG "Elasticsearch error: cluster_block_exception [FORBIDDEN/12/index read-only / allow delete (api)]") |
<!-- dockerfile plugin -->
<plugin>
<groupId>com.spotify</groupId>
<artifactId>dockerfile-maven-plugin</artifactId>
<version>1.3.6</version>
<configuration>
<repository>${docker.image.prefix}/${project.artifactId}</repository>
<tag>${project.version}</tag>
<buildArgs>
<JAR_FILE>target/${project.build.finalName}.jar</JAR_FILE>
</buildArgs>
</configuration>
</plugin>
FROM openjdk:8-jdk-alpine
VOLUME /tmp
ARG JAR_FILE
ADD ${JAR_FILE} app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"]
mvn package
mvn dockerfile:build
docker login
mvn dockerfile:push
docker images
docker rmi -f XXXXXXXXXXX
docker pull niteshkumar/employeesapi-docker:1.0.1
docker run -p 8080:8080 -t niteshkumar/employeesapi-docker:1.0.1
<!--springfox dependency -->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.7.0</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.7.0</version>
</dependency>
package com.engineeernitesh.employeesapi.swagger; import java.util.ArrayList; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import static springfox.documentation.builders.PathSelectors.regex; import springfox.documentation.builders.RequestHandlerSelectors; import springfox.documentation.service.ApiInfo; import springfox.documentation.service.Contact; import springfox.documentation.service.VendorExtension; import springfox.documentation.spi.DocumentationType; import springfox.documentation.spring.web.plugins.Docket; import springfox.documentation.swagger2.annotations.EnableSwagger2; @Configuration @EnableSwagger2 public class SwaggerConfig { @Bean public Docket employeeApi() { return new Docket(DocumentationType.SWAGGER_2) .select() .apis(RequestHandlerSelectors.any()) .paths(regex("/api/employee.*")) .build() .apiInfo(metaData()); } private ApiInfo metaData() { ApiInfo apiInfo = new ApiInfo( "Employee API", "This is test", "1.0", "Terms of service", new Contact("", "", "nitesh04singh@gmail.com"), "Apache License Version 2.0", "https://www.apache.org/licenses/LICENSE-2.0", new ArrayList<VendorExtension>() ); return apiInfo; } }
@ApiOperation(value = "View a list of employees", response = Iterable.class)
List<Employee> getEmployees() {}
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.engineeernitesh</groupId> <artifactId>employeesapi-docker</artifactId> <version>1.0.1</version> <packaging>jar</packaging> <name>Employees database</name> <description>A simple application in which you can store and retrieve employees</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> <relativePath /> </parent> <properties> <docker.image.prefix>niteshkumar</docker.image.prefix> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency> <!-- h2 db --> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <version>1.4.194</version> </dependency> <!--springfox dependency --> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger2</artifactId> <version>2.7.0</version> </dependency> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger-ui</artifactId> <version>2.7.0</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <!-- dockerfile plugin --> <plugin> <groupId>com.spotify</groupId> <artifactId>dockerfile-maven-plugin</artifactId> <version>1.3.6</version> <configuration> <repository>${docker.image.prefix}/${project.artifactId}</repository> <tag>${project.version}</tag> <buildArgs> <JAR_FILE>target/${project.build.finalName}.jar</JAR_FILE> </buildArgs> </configuration> </plugin> </plugins> </build> </project>
package com.engineeernitesh.employeesapi;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
@SpringBootApplication
@EnableJpaRepositories
public class EmployeesApplication {
public static void main(String[] args) {
SpringApplication.run(EmployeesApplication.class, args);
}
}
package com.engineeernitesh.employeesapi;
import io.swagger.annotations.ApiModelProperty;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
@Entity
@Table(name = "employee")
public class Employee {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(notes = "The generated employee id", hidden = true)
private long id;
@ApiModelProperty(notes = "The employees firstname", required = true)
private String firstname;
@ApiModelProperty(notes = "The employees lastname", required = true)
private String lastname;
public Employee(){
}
public Employee(String firstname, String lastname){
this.firstname = firstname;
this.lastname = lastname;
}
/**
* @return the id
*/
public long getId() {
return id;
}
/**
* @param id the id to set
*/
public void setId(long id) {
this.id = id;
}
/**
* @return the firstname
*/
public String getFirstname() {
return firstname;
}
/**
* @param firstname the firstname to set
*/
public void setFirstname(String firstname) {
this.firstname = firstname;
}
/**
* @return the lastname
*/
public String getLastname() {
return lastname;
}
/**
* @param lastname the lastname to set
*/
public void setLastname(String lastname) {
this.lastname = lastname;
}
@Override
public String toString() {
return String.format("Employee[id=%d, code='%s', name='%s']",
id, firstname, lastname);
}
}
package com.engineeernitesh.employeesapi;
import javax.transaction.Transactional;
import org.springframework.data.repository.CrudRepository;
@Transactional
public interface EmployeeRepository extends CrudRepository<Employee, Long> {
Employee findById(long id);
Employee findByLastname(String Lastname);
}
package com.engineeernitesh.employeesapi; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import java.util.ArrayList; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("api/employee") @Api(value="employees-home") public class EmployeesDataController { private final static Logger LOGGER = Logger.getLogger(EmployeesDataController.class.getName()); @Autowired EmployeeRepository employeeRepository; //-------------------Retrieve all employees-------------------------------------------------------- @RequestMapping(value = "", method= RequestMethod.GET, produces = "application/json") @ApiOperation(value = "View a list of employees", response = Iterable.class) List<Employee> getEmployees() { List<Employee> result; LOGGER.log(Level.INFO, "Getting all employees"); result = new ArrayList(); Iterable<Employee> employeeList = employeeRepository.findAll(); for (Employee employee : employeeList) { result.add(employee); } return result; } //-------------------Retrieve a employee by id-------------------------------------------------------- @RequestMapping(value = "/{id}", method= RequestMethod.GET, produces = "application/json") @ApiOperation(value = "Get an employee by id", response = Employee.class) public Employee getEmployee(@PathVariable long id) { Employee result; LOGGER.log(Level.INFO, "Getting employee with id " + id); result = employeeRepository.findById(id); return result; } //-------------------Add an employee-------------------------------------------------------------------- @PreAuthorize("hasRole('ADMIN')") @RequestMapping(method = RequestMethod.POST, produces = "application/text") @ApiOperation(value = "Add a new employee") public ResponseEntity saveEmployee(@RequestBody Employee input) { LOGGER.log(Level.INFO, "Saving employee " + input.getLastname()); Employee employee = new Employee(); employee.setFirstname(input.getFirstname()); employee.setLastname(input.getLastname()); employeeRepository.save(employee); return new ResponseEntity("Employee saved successfully", HttpStatus.OK); } //-------------------Delete a employee by id------------------------------------------------------------ @PreAuthorize("hasRole('ADMIN')") @RequestMapping(value = "/{id}", method = RequestMethod.DELETE, produces = "application/text") @ApiOperation(value = "Delete an employee by id") public ResponseEntity deleteEmployee(@PathVariable long id) { LOGGER.log(Level.INFO, "Deleting employee " + id); employeeRepository.delete(id); return new ResponseEntity("Employee deleted successfully", HttpStatus.OK); } }
### # Database Settings ### spring.datasource.url=jdbc:h2:mem:climbers-db;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE spring.datasource.platform=h2 spring.datasource.username = sa spring.datasource.password = spring.datasource.driverClassName = org.h2.Driver spring.jpa.database-platform=org.hibernate.dialect.H2Dialect ### # H2 Settings ### spring.h2.console.enabled=true spring.h2.console.path=/console spring.h2.console.settings.trace=false spring.h2.console.settings.web-allow-others=false ### # Hibernate Settings ### spring.jpa.hibernate.ddl-auto = update spring.jpa.properties.hibernate.show_sql=false spring.jpa.properties.hibernate.use_sql_comments=false spring.jpa.properties.hibernate.format_sql=false #set sql level to debug to see all the sql statements logging.level.org.hibernate.SQL=debug logging.pattern.console=%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n
INSERT INTO employee (id, firstname, lastname) VALUES (1, 'Nitesh', 'Kumar')
INSERT INTO employee (id, firstname, lastname) VALUES (2, 'Debarshi', 'Da')
INSERT INTO employee (id, firstname, lastname) VALUES (3, 'Sumantra', 'Pal')
