You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I searched in the issues and found nothing similar.
Paimon version
0.6
Compute Engine
Flink
Minimal reproduce step
CREATE CATALOG my_catalog WITH (
'type' = 'paimon',
'warehouse' = 's3://lakehouse/paimon',
's3.endpoint' = 'http://25.30.9.250:9200',
's3.access-key' = 'root',
's3.secret-key' = '12345678'
);
use catalog my_catalog;
CREATE TABLE word_count (
word STRING PRIMARY KEY NOT ENFORCED,
cnt BIGINT
);
What doesn't meet your expectations?
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException: Database default does not exist in Catalog my_catalog.
Anything else?
sql-client log:
Caused by: org.apache.flink.table.catalog.exceptions.DatabaseNotExistException: Database default does not exist in Catalog my_catalog.
at org.apache.paimon.flink.FlinkCatalog.createTable(FlinkCatalog.java:312)
at org.apache.flink.table.catalog.CatalogManager.lambda$createTable$18(CatalogManager.java:957)
at org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:1290)
... 16 more
End of exception on server side>]
at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646) ~[flink-dist-1.18.0.jar:1.18.0]
at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626) ~[flink-dist-1.18.0.jar:1.18.0]
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150) ~[?:?]
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
Are you willing to submit a PR?
I'm willing to submit a PR!
The text was updated successfully, but these errors were encountered:
S3FileIO uses S3AFileSystem of Hadoop, so it cannot be used successfully. Could you consider specifically stating that s3p cannot be used in the usage instructions
Search before asking
Paimon version
0.6
Compute Engine
Flink
Minimal reproduce step
CREATE CATALOG my_catalog WITH (
'type' = 'paimon',
'warehouse' = 's3://lakehouse/paimon',
's3.endpoint' = 'http://25.30.9.250:9200',
's3.access-key' = 'root',
's3.secret-key' = '12345678'
);
use catalog my_catalog;
CREATE TABLE word_count (
word STRING PRIMARY KEY NOT ENFORCED,
cnt BIGINT
);
What doesn't meet your expectations?
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException: Database default does not exist in Catalog my_catalog.
Anything else?
sql-client log:
Caused by: org.apache.flink.table.catalog.exceptions.DatabaseNotExistException: Database default does not exist in Catalog my_catalog.
at org.apache.paimon.flink.FlinkCatalog.createTable(FlinkCatalog.java:312)
at org.apache.flink.table.catalog.CatalogManager.lambda$createTable$18(CatalogManager.java:957)
at org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:1290)
... 16 more
End of exception on server side>]
at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646) ~[flink-dist-1.18.0.jar:1.18.0]
at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626) ~[flink-dist-1.18.0.jar:1.18.0]
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150) ~[?:?]
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: