Skip to content

Commit aa2d0c4

Browse files
authored
[lake/paimon] Fluss and Paimon data type mapping document adds binary and bytes data types. (#940)
1 parent 98f34df commit aa2d0c4

File tree

2 files changed

+4
-3
lines changed
  • fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon
  • website/docs/streaming-lakehouse/integrate-data-lakes

2 files changed

+4
-3
lines changed

fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/PaimonLakeCatalog.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import com.alibaba.fluss.lakehouse.lakestorage.LakeCatalog;
2323
import com.alibaba.fluss.metadata.TableDescriptor;
2424
import com.alibaba.fluss.metadata.TablePath;
25+
import com.alibaba.fluss.utils.IOUtils;
2526

2627
import org.apache.paimon.CoreOptions;
2728
import org.apache.paimon.catalog.Catalog;
@@ -175,8 +176,6 @@ private void setFlussProperty(String key, String value, Options options) {
175176

176177
@Override
177178
public void close() throws Exception {
178-
if (paimonCatalog != null) {
179-
paimonCatalog.close();
180-
}
179+
IOUtils.closeQuietly(paimonCatalog, "paimon catalog");
181180
}
182181
}

website/docs/streaming-lakehouse/integrate-data-lakes/paimon.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,3 +126,5 @@ The following content shows the mapping between [Fluss data type](table-design/d
126126
| TIME | TIME |
127127
| TIMESTAMP | TIMESTAMP |
128128
| TIMESTAMP WITH LOCAL TIMEZONE | TIMESTAMP WITH LOCAL TIMEZONE |
129+
| BINARY | BINARY |
130+
| BYTES | BYTES |

0 commit comments

Comments
 (0)