File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -187,7 +187,10 @@ describe('Arrow support', () => {
187187 'should handle LZ4 compressed data' ,
188188 createTest (
189189 async ( session ) => {
190- const operation = await session . executeStatement ( `SELECT * FROM ${ tableName } ` ) ;
190+ const operation = await session . executeStatement (
191+ `SELECT * FROM ${ tableName } ` ,
192+ { useCloudFetch : false } , // Explicitly disable cloud fetch to test LZ4 compression
193+ ) ;
191194 const result = await operation . fetchAll ( ) ;
192195 expect ( fixArrowResult ( result ) ) . to . deep . equal ( expectedArrow ) ;
193196
Original file line number Diff line number Diff line change @@ -97,11 +97,11 @@ describe('CloudFetch', () => {
9797 expect ( fetchedRowCount ) . to . be . equal ( queriedRowsCount ) ;
9898 } ) ;
9999
100- it ( 'should handle LZ4 compressed data ' , async ( ) => {
100+ it ( 'should not use LZ4 compression with cloud fetch ' , async ( ) => {
101101 const cloudFetchConcurrentDownloads = 5 ;
102102 const session = await openSession ( {
103103 cloudFetchConcurrentDownloads,
104- useLZ4Compression : true ,
104+ useLZ4Compression : true , // This is ignored when cloud fetch is enabled
105105 } ) ;
106106
107107 const queriedRowsCount = 10000000 ; // result has to be quite big to enable CloudFetch
@@ -126,7 +126,8 @@ describe('CloudFetch', () => {
126126 expect ( resultHandler ) . to . be . instanceof ( ResultSlicer ) ;
127127 expect ( resultHandler . source ) . to . be . instanceof ( ArrowResultConverter ) ;
128128 expect ( resultHandler . source . source ) . to . be . instanceOf ( CloudFetchResultHandler ) ;
129- expect ( resultHandler . source . source . isLZ4Compressed ) . to . be . true ;
129+ // LZ4 compression should not be enabled with cloud fetch
130+ expect ( resultHandler . source . source . isLZ4Compressed ) . to . be . false ;
130131
131132 const chunk = await operation . fetchChunk ( { maxRows : 100000 , disableBuffering : true } ) ;
132133 expect ( chunk . length ) . to . be . gt ( 0 ) ;
You can’t perform that action at this time.
0 commit comments