Skip to content

Commit 435f0b7

Browse files
committed
fix
1 parent 4e30520 commit 435f0b7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

fluss-lake/fluss-lake-lance/src/main/java/com/alibaba/fluss/lake/lance/LanceLakeStorage.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import com.alibaba.fluss.config.Configuration;
2121
import com.alibaba.fluss.lake.lakestorage.LakeStorage;
2222
import com.alibaba.fluss.lake.lance.tiering.LanceCommittable;
23+
import com.alibaba.fluss.lake.lance.tiering.LanceLakeTieringFactory;
2324
import com.alibaba.fluss.lake.lance.tiering.LanceWriteResult;
2425
import com.alibaba.fluss.lake.writer.LakeTieringFactory;
2526

@@ -33,7 +34,7 @@ public LanceLakeStorage(Configuration configuration) {
3334

3435
@Override
3536
public LakeTieringFactory<LanceWriteResult, LanceCommittable> createLakeTieringFactory() {
36-
throw new UnsupportedOperationException("Not implemented");
37+
return new LanceLakeTieringFactory(config);
3738
}
3839

3940
@Override

0 commit comments

Comments
 (0)