diff --git a/optimus/io/jdbc.py b/optimus/io/jdbc.py index fd2943a3..6141eb29 100644 --- a/optimus/io/jdbc.py +++ b/optimus/io/jdbc.py @@ -57,7 +57,7 @@ def __init__(self, host, database, user, password, port=None, driver=None, schem self.user = user self.password = password self.schema = schema - print(self.url) + logger.print(self.url) def tables(self, schema=None, database=None, limit=None): """ @@ -148,7 +148,6 @@ def execute(self, query, limit=None): logger.print(query) logger.print(self.url) - print(self.url) conf = Spark.instance.spark.read \ .format(