[flink-table-store] branch master updated: [hotfix] Fix options in FlinkSinkBuilder

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new aba5e166 [hotfix] Fix options in FlinkSinkBuilder
aba5e166 is described below

commit aba5e166b69d1a8437222988f777fa004268980f
Author: Shammon FY <zjur...@gmail.com>
AuthorDate: Tue Feb 14 10:20:48 2023 +0800

    [hotfix] Fix options in FlinkSinkBuilder
    
    This closes #530
---
 .../apache/flink/table/store/connector/sink/FlinkSinkBuilder.java   | 2 +-
 .../table/store/connector/sink/FileStoreShuffleBucketTest.java      | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSinkBuilder.java
 
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSinkBuilder.java
index 7d0e570c..7358201d 100644
--- 
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSinkBuilder.java
+++ 
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSinkBuilder.java
@@ -89,7 +89,7 @@ public class FlinkSinkBuilder {
                         table.schema(),
                         table.options()
                                 .toConfiguration()
-                                
.getBoolean(FlinkConnectorOptions.SINK_SHUFFLE_BY_PARTITION));
+                                
.get(FlinkConnectorOptions.SINK_SHUFFLE_BY_PARTITION));
         PartitionTransformation<RowData> partitioned =
                 new PartitionTransformation<>(input.getTransformation(), 
partitioner);
         if (parallelism != null) {
diff --git 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/FileStoreShuffleBucketTest.java
 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/FileStoreShuffleBucketTest.java
index c7588063..eeff959b 100644
--- 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/FileStoreShuffleBucketTest.java
+++ 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/FileStoreShuffleBucketTest.java
@@ -36,8 +36,8 @@ import 
org.apache.flink.table.store.table.FileStoreTableFactory;
 import org.apache.flink.table.store.table.sink.SinkRecord;
 import org.apache.flink.table.types.logical.RowType;
 
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -53,7 +53,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
 public class FileStoreShuffleBucketTest extends CatalogITCaseBase {
     private static final int TOTAL_SOURCE_RECORD_COUNT = 1000;
 
-    @Before
+    @BeforeEach
     public void after() throws Exception {
         super.before();
         CollectStoreSinkWrite.writeRowsMap.clear();