[ 
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)

Reply via email to