beryllw commented on issue #1412:
URL: https://github.com/apache/fluss/issues/1412#issuecomment-3130282400
Steps to Reproduce:
1. Modify server.yml to set the data lake format:`table.datalake.format:
paimon`
2. Start Local Cluster by: /usr/local/fluss/bin/local-cluster.sh start
```
coordinator-server:bind.listeners: FLUSS://{ip}:9123
tablet-server:bind.listeners: FLUSS://{ip}:9124
```
4. Create Primary Key Table```CREATE TABLE IF NOT EXISTS
fluss_catalog.fluss.test_prefix_look_up (
`dt` STRING,
`user_id` STRING,
`order_id` STRING,
`log_time` BIGINT,
PRIMARY KEY (
`dt`,
`user_id`,
`order_id`
) NOT ENFORCED
) PARTITIONED BY (dt) WITH (
'bucket.key' = 'user_id',
'bucket.num' = '2',
'table.auto-partition.enabled' = 'true',
'table.auto-partition.time-unit' = 'DAY',
'table.auto-partition.num-precreate' = '1',
'table.auto-partition.num-retention' = '3',
'table.auto-partition.time-zone' = 'Asia/Shanghai'
);
```
4. Insert Test Data:
```
INSERT INTO fluss_catalog.fluss.test_prefix_look_up VALUES ('20250728',
'prefix_look_up_paimon_test', '1234567890123456789', 1);
```
5. Execute prefix look up query:
```java
LookupResult lookup =
table.newLookup().lookupBy("dt","user_id").createLookuper().lookup(FlussAsyncLookUp.row("20250728","prefix_look_up_paimon_test")).get();
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
