File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/sink Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change 3333import org .slf4j .Logger ;
3434import org .slf4j .LoggerFactory ;
3535
36+ import java .util .Arrays ;
3637import java .util .HashMap ;
3738import java .util .List ;
3839import java .util .Map ;
@@ -115,12 +116,8 @@ public FlussSinkBuilder<InputT> setPartialUpdateColumns(List<String> columns) {
115116 * Convenience varargs overload.
116117 */
117118 public FlussSinkBuilder <InputT > setPartialUpdateColumns (String ... columns ) {
118- if (columns == null ) {
119- this .partialUpdateColumns = null ;
120- } else {
121- this .partialUpdateColumns = java .util .Arrays .asList (columns );
122- }
123- return this ;
119+ return setPartialUpdateColumns (
120+ columns == null ? null : Arrays .asList (columns ));
124121 }
125122
126123 /** Set a configuration option. */
You can’t perform that action at this time.
0 commit comments