1717
1818package org .apache .doris .flink .sink .batch ;
1919
20- import org .apache .doris .flink .sink .writer .LoadConstants ;
2120import org .apache .flink .api .common .time .Deadline ;
2221
2322import org .apache .doris .flink .cfg .DorisExecutionOptions ;
2726import org .apache .doris .flink .sink .HttpTestUtil ;
2827import org .apache .doris .flink .sink .TestUtil ;
2928import org .apache .doris .flink .sink .writer .LabelGenerator ;
29+ import org .apache .doris .flink .sink .writer .LoadConstants ;
3030import org .apache .http .client .methods .CloseableHttpResponse ;
3131import org .apache .http .impl .client .CloseableHttpClient ;
3232import org .apache .http .impl .client .HttpClientBuilder ;
@@ -233,7 +233,8 @@ public void mergeBufferTest() {
233233 public void mergeBufferNullDelimiterTest () {
234234 DorisReadOptions readOptions = DorisReadOptions .builder ().build ();
235235 Properties streamProperties = new Properties ();
236- streamProperties .setProperty (LoadConstants .FORMAT_KEY , LoadConstants .ARROW ); // this makes lineDelimiter null
236+ streamProperties .setProperty (
237+ LoadConstants .FORMAT_KEY , LoadConstants .ARROW ); // this makes lineDelimiter null
237238 DorisExecutionOptions executionOptions =
238239 DorisExecutionOptions .builder ().setStreamLoadProp (streamProperties ).build ();
239240 DorisOptions options =
@@ -248,12 +249,10 @@ public void mergeBufferNullDelimiterTest() {
248249 options , readOptions , executionOptions , new LabelGenerator ("xx" , false ), 0 );
249250
250251 List <BatchRecordBuffer > bufferList = new ArrayList <>();
251- BatchRecordBuffer recordBuffer =
252- new BatchRecordBuffer ("db" , "tbl" , null , 0 );
252+ BatchRecordBuffer recordBuffer = new BatchRecordBuffer ("db" , "tbl" , null , 0 );
253253 recordBuffer .insert ("111" .getBytes (StandardCharsets .UTF_8 ));
254254 recordBuffer .setLabelName ("label2" );
255- BatchRecordBuffer buffer =
256- new BatchRecordBuffer ("db" , "tbl" , null , 0 );
255+ BatchRecordBuffer buffer = new BatchRecordBuffer ("db" , "tbl" , null , 0 );
257256 buffer .insert ("222" .getBytes (StandardCharsets .UTF_8 ));
258257 buffer .setLabelName ("label1" );
259258
0 commit comments