[jira] [Updated] (CARBONDATA-2725) Exception thrown in awaitResult when set carbon.search.enabled=true and concurrent select query executed

[Akash R Nilugal (Jira)]

     [ https://issues.apache.org/jira/browse/CARBONDATA-2725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chetan Bhat updated CARBONDATA-2725:
------------------------------------
    Description:
Steps:

In Beeline user executes set carbon.search.enabled=true

In Beeline user creates table and loads data.

create table Test_Boundary (c1_int int,c2_Bigint Bigint,c3_Decimal Decimal(38,38),c4_double double,c5_string string,c6_Timestamp Timestamp,c7_Datatype_Desc string) STORED BY 'org.apache.carbondata.format' TBLPROPERTIES('table_blocksize'='512','local_dictionary_enable'='true','local_dictionary_threshold'='1','local_dictionary_include'='c5_string');
 LOAD DATA INPATH 'hdfs://hacluster/chetan/Test_Data1.csv' INTO table Test_Boundary OPTIONS('DELIMITER'=',','QUOTECHAR'='','BAD_RECORDS_ACTION'='FORCE','FILEHEADER'='');

 

From 5 concurrent beeline sessions user executes the select query

select  c1_int  from test_boundary where round(c1_int,1)=NULL;

Actual output - Exception thrown in awaitResult when set carbon.search.enabled=true and concurrent select query executed.

 

0: jdbc:hive2://10.18.98.101:22550/default> select c1_int from test_boundary where round(c1_int,1)=NULL;
 Error: org.apache.spark.SparkException: Exception thrown in awaitResult: (state=,code=0)

Expected - The concurrent select query execution should be successful.

  was:
Steps:

In Beeline user executes set carbon.search.enabled=true

In Beeline user creates table and loads data.

create table Test_Boundary (c1_int int,c2_Bigint Bigint,c3_Decimal Decimal(38,38),c4_double double,c5_string string,c6_Timestamp Timestamp,c7_Datatype_Desc string) STORED BY 'org.apache.carbondata.format' TBLPROPERTIES('table_blocksize'='512','local_dictionary_enable'='true','local_dictionary_threshold'='1','local_dictionary_include'='c5_string');
LOAD DATA INPATH 'hdfs://hacluster/chetan/Test_Data1.csv' INTO table Test_Boundary OPTIONS('DELIMITER'=',','QUOTECHAR'='','BAD_RECORDS_ACTION'='FORCE','FILEHEADER'='');

 

From 5 concurrent beeline sessions user executes the select query

select  c1_int  from test_boundary where round(c1_int,1)=NULL;

Actual output - Exception thrown in awaitResult when set carbon.search.enabled=true and concurrent select query executed.

!image-2018-07-11-14-43-51-444.png!

0: jdbc:hive2://10.18.98.101:22550/default> select c1_int from test_boundary where round(c1_int,1)=NULL;
Error: org.apache.spark.SparkException: Exception thrown in awaitResult: (state=,code=0)

Expected - The concurrent select query execution should be successful.

> Exception thrown in awaitResult when set carbon.search.enabled=true and concurrent select query executed
> --------------------------------------------------------------------------------------------------------
>
>                 Key: CARBONDATA-2725
>                 URL: https://issues.apache.org/jira/browse/CARBONDATA-2725
>             Project: CarbonData
>          Issue Type: Bug
>          Components: data-query
>    Affects Versions: 1.4.1
>         Environment: Spark 2.1
>            Reporter: Chetan Bhat
>            Priority: Minor
>
> Steps:
> In Beeline user executes set carbon.search.enabled=true
> In Beeline user creates table and loads data.
> create table Test_Boundary (c1_int int,c2_Bigint Bigint,c3_Decimal Decimal(38,38),c4_double double,c5_string string,c6_Timestamp Timestamp,c7_Datatype_Desc string) STORED BY 'org.apache.carbondata.format' TBLPROPERTIES('table_blocksize'='512','local_dictionary_enable'='true','local_dictionary_threshold'='1','local_dictionary_include'='c5_string');
>  LOAD DATA INPATH 'hdfs://hacluster/chetan/Test_Data1.csv' INTO table Test_Boundary OPTIONS('DELIMITER'=',','QUOTECHAR'='','BAD_RECORDS_ACTION'='FORCE','FILEHEADER'='');
>  
> From 5 concurrent beeline sessions user executes the select query
> select  c1_int  from test_boundary where round(c1_int,1)=NULL;
> Actual output - Exception thrown in awaitResult when set carbon.search.enabled=true and concurrent select query executed.
>  
> 0: jdbc:hive2://10.18.98.101:22550/default> select c1_int from test_boundary where round(c1_int,1)=NULL;
>  Error: org.apache.spark.SparkException: Exception thrown in awaitResult: (state=,code=0)
> Expected - The concurrent select query execution should be successful.

--
This message was sent by Atlassian JIRA
(v7.6.3#76005)