Skip to content

Commit

Permalink
clean again
Browse files Browse the repository at this point in the history
  • Loading branch information
StrikeW committed Apr 30, 2024
1 parent 32cf9b7 commit 8198e6a
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions src/connector/src/source/cdc/external/postgres.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,8 @@

use std::cmp::Ordering;
use std::collections::HashMap;
use std::error::Error;

use anyhow::Context;
use bytes::BytesMut;
use futures::stream::BoxStream;
use futures::{pin_mut, StreamExt};
use futures_async_stream::try_stream;
Expand All @@ -26,11 +24,10 @@ use openssl::ssl::{SslConnector, SslMethod, SslVerifyMode};
use postgres_openssl::MakeTlsConnector;
use risingwave_common::catalog::Schema;
use risingwave_common::row::{OwnedRow, Row};
use risingwave_common::types::Datum;
use risingwave_common::util::iter_util::ZipEqFast;
use serde_derive::{Deserialize, Serialize};
use thiserror_ext::AsReport;
use tokio_postgres::types::{to_sql_checked, IsNull, PgLsn, ToSql, Type as PgType};
use tokio_postgres::types::PgLsn;
use tokio_postgres::{NoTls, Statement};

use crate::error::{ConnectorError, ConnectorResult};
Expand Down

0 comments on commit 8198e6a

Please sign in to comment.