Skip to content

duckdb_moncake cannot select pg_moncake data #2

@l1t1

Description

@l1t1

I use the docker image

docker pull docker.1ms.run/mooncakelabs/pg_mooncake

docker run --name mooncake2duckdb --rm -e POSTGRES_PASSWORD=password -v /mnt/c/d:/par --net=host docker.1ms.run/mooncakelabs/pg_mooncake

in another terminal

docker exec -it mooncake2duck bash
 psql
psql (17.6 (Debian 17.6-1.pgdg12+1))
Type "help" for help.

postgres=# CREATE TABLE trades(
  id bigint PRIMARY KEY,
  symbol text,
  time timestamp,
  price real
);
CREATE TABLE
postgres=# CREATE EXTENSION pg_mooncake CASCADE;
CREATE EXTENSION
postgres=# CALL mooncake.create_table('trades_iceberg', 'trades');
CALL
postgres=# INSERT INTO trades VALUES
  (1,  'AMD', '2024-06-05 10:00:00', 119),
  (2, 'AMZN', '2024-06-05 10:05:00', 207),
  (3, 'AAPL', '2024-06-05 10:10:00', 203),
  (4, 'AMZN', '2024-06-05 10:15:00', 210);
INSERT 0 4
postgres=# select * from trades;
 id | symbol |        time         | price
----+--------+---------------------+-------
  1 | AMD    | 2024-06-05 10:00:00 |   119
  2 | AMZN   | 2024-06-05 10:05:00 |   207
  3 | AAPL   | 2024-06-05 10:10:00 |   203
  4 | AMZN   | 2024-06-05 10:15:00 |   210
(4 rows)

postgres=# select * from trades_iceberg;
 id | symbol |        time         | price
----+--------+---------------------+-------
  1 | AMD    | 2024-06-05 10:00:00 |   119
  2 | AMZN   | 2024-06-05 10:05:00 |   207
  3 | AAPL   | 2024-06-05 10:10:00 |   203
  4 | AMZN   | 2024-06-05 10:15:00 |   210
(4 rows)

postgres=# \q
postgres@DESKTOP-59T6U68:/$ /par/duckdb140
DuckDB v1.4.0 (Andium) b8a06e4a22
Enter ".help" for usage hints.
Connected to a transient in-memory database.
Use ".open FILENAME" to reopen on a persistent database.
D .system ls /var/lib/postgresql/data/pg_mooncake/
moonlink_metadata_store.sqlite  moonlink.sock  postgres.public.trades_iceberg  read_through_cache  temp  _wal
D ATTACH DATABASE 'mooncake' (TYPE mooncake, URI '/var/lib/postgresql/data/pg_mooncake/moonlink.sock', DATABASE 'postgres');
D use mooncake;
D select * from trades_iceberg;
Error:
IO error (permanent) at /root/.cargo/git/checkouts/moonlink-2e8e5fe2638baa36/f1d6ead/src/moonlink_rpc/src/lib.rs:50:5, source: early eof
D load mooncake;
D select * from trades_iceberg;
Error:
IO error (temporary) at /root/.cargo/git/checkouts/moonlink-2e8e5fe2638baa36/f1d6ead/src/moonlink_rpc/src/lib.rs:43:5, source: Broken pipe (os error 32)
D select * from postgres.public.trades_iceberg;
Binder Error:
Catalog "postgres" does not exist!
D select * from mooncake.public.trades_iceberg;
Error:
IO error (temporary) at /root/.cargo/git/checkouts/moonlink-2e8e5fe2638baa36/f1d6ead/src/moonlink_rpc/src/lib.rs:43:5, source: Broken pipe (os error 32)

in server logs

thread 'tokio-runtime-worker' panicked at /pg_mooncake/moonlink/src/moonlink_service/src/rpc_server.rs:67:27:
Unexpected Unix RPC server error: Backend error (permanent) at /pg_mooncake/moonlink/src/moonlink_service/src/rpc_server.rs:137:32, source: Moonlink connector error (permanent) at /pg_mooncake/moonlink/src/moonlink_backend/src/lib.rs:303:38, source: Table postgres.main.trades_iceberg not found (permanent) at moonlink/src/moonlink_connectors/src/replication_manager.rs:359:28
stack backtrace:

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions