diff --git a/ansible/group_vars/all/all.yml b/ansible/group_vars/all/all.yml index a948ab0377a84c33781f0ba2f9502a0e33f36125..a690bf3fe19535b5360ad6068cd82f79575b92da 100644 --- a/ansible/group_vars/all/all.yml +++ b/ansible/group_vars/all/all.yml @@ -344,6 +344,9 @@ service_kerberos_type: 'HTTPS' nxcals_security_rbac_role_prefix: "{{nxcals_namespace | replace('_', '-') | upper}}-" service_rbac_login_policy: "LOCATION" +service_hbase_rpc_timeout: 60000 +service_hbase_client_operation_timeout: 1200000 + #NXCALS - Monitoring-grok ################################################################################# monitoring_grok_memory: "-Xms64m -Xmx128m" diff --git a/ansible/roles/service/templates/config/application.properties b/ansible/roles/service/templates/config/application.properties index 24b55db80723254ddfd7f458a197295b3c6c0d78..6cf2b573f215eb1964bf060bce7b2129734b00da 100644 --- a/ansible/roles/service/templates/config/application.properties +++ b/ansible/roles/service/templates/config/application.properties @@ -54,6 +54,8 @@ data.location.hbase-namespace={{hbase_namespace}} data.location.date-granularity = DAYS data.location.date-grouping-type={{date_grouping_type}} data.location.adaptive-extraction-enabled={{service_extraction_adaptive_enabled}} +data.location.hbase.rpc.timeout={{service_hbase_rpc_timeout}} +data.location.hbase.client.operation.timeout={{service_hbase_client_operation_timeout}} service.kerberos.keytab={{service_kerberos_keytab}} service.kerberos.realm={{service_kerberos_realm}} service.kerberos.type={{service_kerberos_type}} diff --git a/service/src/main/java/cern/nxcals/service/config/DataAccessConfig.java b/service/src/main/java/cern/nxcals/service/config/DataAccessConfig.java index 1fda4ae9ef698f5e40ea50ecb9e6b54367cbd73a..7a32366a2939433cc8d6074ef8f5f702b37ef63a 100644 --- a/service/src/main/java/cern/nxcals/service/config/DataAccessConfig.java +++ b/service/src/main/java/cern/nxcals/service/config/DataAccessConfig.java @@ -66,6 +66,10 @@ public class DataAccessConfig { @Bean @DependsOn("kerberos") public Connection hbaseConnection() throws IOException { - return ConnectionFactory.createConnection(HBaseConfiguration.create()); + org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create(); + config.setInt("hbase.rpc.timeout", properties.getHbaseRpcTimeout()); + config.setInt("hbase.client.operation.timeout", properties.getHbaseClientOperationTimeout()); + + return ConnectionFactory.createConnection(HBaseConfiguration.create(config)); } } \ No newline at end of file diff --git a/service/src/main/java/cern/nxcals/service/config/DataLocationProperties.java b/service/src/main/java/cern/nxcals/service/config/DataLocationProperties.java index 22b6a85c4cd663a03546d5a07c6cf8605ec175d1..685b5e23924eeb4949953f6bb738f06e62ffca75 100644 --- a/service/src/main/java/cern/nxcals/service/config/DataLocationProperties.java +++ b/service/src/main/java/cern/nxcals/service/config/DataLocationProperties.java @@ -19,4 +19,6 @@ public class DataLocationProperties { private ChronoUnit dateGranularity = ChronoUnit.DAYS; private DateGroupingType dateGroupingType = DateGroupingType.DAYS; private boolean adaptiveExtractionEnabled = false; + private int hbaseRpcTimeout = 60000; + private int hbaseClientOperationTimeout = 1200000; }