Skip to content

Commit 186fbcb

Browse files
committed
fix type
1 parent 6e06ce4 commit 186fbcb

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/risedevtool/src/task/postgres_service.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ impl DockerServiceConfig for PostgresConfig {
3030

3131
fn args(&self) -> Vec<String> {
3232
// Enable CDC.
33-
["-c", "wal_level=logical", "-c", "max_replication_slots=30"]
33+
["-c", "wal_level=logical", "-c", "max_replication_slots=30", "-c", "log_statement=all"]
3434
.map(String::from)
3535
.to_vec()
3636
}

src/stream/src/from_proto/sink.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -371,7 +371,7 @@ mod tests {
371371
assert_eq!(jdbc_url.host, "localhost");
372372
assert_eq!(jdbc_url.port, 5432);
373373
assert_eq!(jdbc_url.db_name, "test");
374-
assert_eq!(jdbc_url.username, Some("postgres"));
375-
assert_eq!(jdbc_url.password, Some("postgres"));
374+
assert_eq!(jdbc_url.username, Some("postgres".to_owned()));
375+
assert_eq!(jdbc_url.password, Some("postgres".to_owned()));
376376
}
377377
}

0 commit comments

Comments
 (0)