Функция Apache Ibis ImpalaClient.close() не работает

Все,

После создания подключения к HDFS/Impala и выполнения функции exists_table() я обычно использую close() для очистки всего сеанса подключения. Но я заметил, что если я сначала закрою соединение, функция create_table() все равно будет работать. Это означает, что функция ImpalaClient.close() не работает и сеанс подключения будет сохранен в пуле. Как мне действительно очистить эти связи?

import ibis

hdfs = ibis.hdfs_connect(host=localhost, port=9870)
client = ibis.impala.connect(host=localhost, port=21050, database='demo_db', timeout=45, hdfs_client=hdfs)

client.close()

schema = ibis.schema([('foo', 'string'),
                      ('year', 'int32'),
                      ('month', 'int16')])
name = 'new_table'
client.create_table(name, schema=schema, partition=['year', 'month'])
print(client.exists_table("new_table"))
True

Благодарность,

Эрик

0 ответов

Другие вопросы по тегам