diff --git a/flink-python/pyflink/table/catalog.py b/flink-python/pyflink/table/catalog.py index e2ac78eb9ef30..561d9032c0bc7 100644 --- a/flink-python/pyflink/table/catalog.py +++ b/flink-python/pyflink/table/catalog.py @@ -1138,7 +1138,6 @@ def __init__(self, catalog_name: str, default_database: str, username: str, pwd: assert pwd is not None assert base_url is not None - from pyflink.java_gateway import get_gateway gateway = get_gateway() j_jdbc_catalog = gateway.jvm.org.apache.flink.connector.jdbc.catalog.JdbcCatalog(