fix imports

Author: xx789633

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/IcebergLakeWriter.java

@@ -23,8 +23,8 @@
 import com.alibaba.fluss.lake.writer.WriterInitContext;
 import com.alibaba.fluss.metadata.TablePath;
 import com.alibaba.fluss.record.LogRecord;
+import com.alibaba.fluss.shaded.guava32.com.google.common.collect.Lists;
 
-import com.google.common.collect.Lists;
 import org.apache.iceberg.FileFormat;
 import org.apache.iceberg.PartitionSpec;
 import org.apache.iceberg.Schema;

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/writer/DeltaTaskWriter.java

@@ -20,9 +20,9 @@
 import com.alibaba.fluss.lake.iceberg.tiering.RecordWriter;
 import com.alibaba.fluss.metadata.TableBucket;
 import com.alibaba.fluss.record.LogRecord;
+import com.alibaba.fluss.shaded.guava32.com.google.common.collect.Lists;
 import com.alibaba.fluss.types.RowType;
 
-import com.google.common.collect.Lists;
 import org.apache.iceberg.FileFormat;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.Table;
@@ -99,8 +99,10 @@ public void write(LogRecord record) throws Exception {
                 break;
             case UPDATE_BEFORE:
                 deltaWriter.delete(flussRecordAsIcebergRecord);
+                break;
             case DELETE:
                 deltaWriter.delete(flussRecordAsIcebergRecord);
+                break;
             default:
                 throw new UnsupportedOperationException(
                         "Unknown row kind: " + record.getChangeType());