Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
chenzl25 committed Sep 18, 2024
1 parent 8d87618 commit 0046100
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions risedev.yml
Original file line number Diff line number Diff line change
@@ -127,8 +127,8 @@ profile:
RW_DATA_DIRECTORY: "data-dir"
AWS_ACCESS_KEY_ID: "hummockadmin"
AWS_SECRET_ACCESS_KEY: "hummockadmin"
RW_POSTGRES_USERNAME: "xxx"
RW_POSTGRES_PASSWORD: "xxx"
RW_SQL_USERNAME: "xxx"
RW_SQL_PASSWORD: "xxx"
RW_SQL_ENDPOINT: "sqlite won't be used"
RW_SQL_DATABASE: "/tmp/sqlite/iceberg.db"
CONNECTOR_LIBS_PATH: ".risingwave/bin/connector-node/libs"
8 changes: 4 additions & 4 deletions src/frontend/src/handler/create_table.rs
Original file line number Diff line number Diff line change
@@ -1357,12 +1357,12 @@ pub async fn handle_create_table(
bail!("To create an iceberg engine table, RW_SQL_DATABASE needed to be set");
};

let Ok(meta_store_user) = std::env::var("RW_POSTGRES_USERNAME") else {
bail!("To create an iceberg engine table, RW_POSTGRES_USERNAME needed to be set");
let Ok(meta_store_user) = std::env::var("RW_SQL_USERNAME") else {
bail!("To create an iceberg engine table, RW_SQL_USERNAME needed to be set");
};

let Ok(meta_store_password) = std::env::var("RW_POSTGRES_PASSWORD") else {
bail!("To create an iceberg engine table, RW_POSTGRES_PASSWORD needed to be set");
let Ok(meta_store_password) = std::env::var("RW_SQL_PASSWORD") else {
bail!("To create an iceberg engine table, RW_SQL_PASSWORD needed to be set");
};

let rw_db_name = session

0 comments on commit 0046100

Please sign in to comment.