@@ -250,7 +250,7 @@ public async Task TestInsertAlignedStringRecords()
250250 while ( res . HasNext ( ) ) Console . WriteLine ( res . Next ( ) ) ;
251251
252252 await res . Close ( ) ;
253-
253+
254254 // large data test
255255 device_id = new List < string > ( ) { } ;
256256 measurements_lst = new List < List < string > > ( ) { } ;
@@ -402,18 +402,19 @@ public async Task TestInsertAlignedRecordsOfOneDevice()
402402 await session_pool . Close ( ) ;
403403 Console . WriteLine ( "TestInsertAlignedRecordsOfOneDevice Passed!" ) ;
404404 }
405- public async Task TestInsertAlignedStringRecordsOfOneDevice ( ) {
405+ public async Task TestInsertAlignedStringRecordsOfOneDevice ( )
406+ {
406407 var session_pool = new SessionPool ( host , port , pool_size ) ;
407408 await session_pool . Open ( false ) ;
408- if ( debug ) session_pool . OpenDebugMode ( ) ;
409+ if ( debug ) session_pool . OpenDebugMode ( ) ;
409410
410411 System . Diagnostics . Debug . Assert ( session_pool . IsOpen ( ) ) ;
411412 var status = 0 ;
412413 await session_pool . DeleteStorageGroupAsync ( test_group_name ) ;
413414 var device_id = string . Format ( "{0}.{1}" , test_group_name , test_device ) ;
414415 var measurements = new List < string > ( ) { test_measurements [ 0 ] , test_measurements [ 1 ] , test_measurements [ 2 ] } ;
415416 var data_type_lst = new List < TSDataType > ( ) { TSDataType . TEXT , TSDataType . TEXT , TSDataType . TEXT } ;
416- var encoding_lst = new List < TSEncoding > ( ) { TSEncoding . PLAIN , TSEncoding . PLAIN , TSEncoding . PLAIN } ;
417+ var encoding_lst = new List < TSEncoding > ( ) { TSEncoding . PLAIN , TSEncoding . PLAIN , TSEncoding . PLAIN } ;
417418 var compressor_lst = new List < Compressor > ( ) { Compressor . SNAPPY , Compressor . SNAPPY , Compressor . SNAPPY } ;
418419 status = await session_pool . CreateAlignedTimeseriesAsync ( device_id , measurements , data_type_lst , encoding_lst , compressor_lst ) ;
419420 System . Diagnostics . Debug . Assert ( status == 0 ) ;
0 commit comments